ConsumerRunConfig

Kind: Type

Source: packages/microservices/external/kafka.interface.ts

Part of: Microservices

Definition

ts
{ autoCommit?: boolean; autoCommitInterval?: number | null; autoCommitThreshold?: number | null; eachBatchAutoResolve?: boolean; partitionsConsumedConcurrently?: number; eachBatch?: EachBatchHandler; eachMessage?: EachMessageHandler; }