IKafkaConsumer

Index

Properties

• eachBatch
• eachMessage

Properties

optionaleachBatch

eachBatch?: EachBatchHandler

optionaleachMessage

eachMessage?: EachMessageHandler