Interface KafkaOptions

Type declaration

• Optional client?: KafkaConfig

• Optional consumer?: ConsumerConfig

• Optional deserializer?: Deserializer

• Optional producer?: ProducerConfig

• Optional run?: { autoCommit?: boolean; autoCommitInterval?: number | null; autoCommitThreshold?: number | null; eachBatchAutoResolve?: boolean; partitionsConsumedConcurrently?: number }

  • Optional autoCommit?: boolean

  • Optional autoCommitInterval?: number | null

  • Optional autoCommitThreshold?: number | null

  • Optional eachBatchAutoResolve?: boolean

  • Optional partitionsConsumedConcurrently?: number

• Optional send?: { acks?: number; compression?: CompressionTypes; timeout?: number }

  • Optional acks?: number

  • Optional compression?: CompressionTypes

  • Optional timeout?: number

• Optional serializer?: Serializer

• Optional subscribe?: { fromBeginning?: boolean }

  • Optional fromBeginning?: boolean