NewAsyncProducer create new kafka producer.

NewAsyncProducerWithCallback create new kafka producer with callback for delete invalid projection.

NewAsyncWriter create new configured kafka async writer.

NewAsyncWriterWithCallback create new configured kafka async writer.

NewConsumerGroup kafka consumer group constructor.

NewKafkaConn create new kafka connection.

NewKafkaReader create new configured kafka reader.

NewProducer create new kafka producer.

NewRequireNoneProducer create new fire and forget kafka producer.

NewRequireNoneWriter create new configured kafka writer.

NewWriter create new configured kafka writer.

Config kafka config.

MessageProcessor processor methods must implement kafka.Worker func method interface.

Worker kafka consumer worker fetch and process messages from reader.

WorkerErrGroup kafka consumer worker fetch and process messages from reader.