NewConsumer for creating a new Consumer instance.

NewConsumerWithPrefix for creating a new Consumer instance.

NewProducer for creating a new Producer instance.

NewProducerWithPrefix for creating a new Producer instance.

NewSyncProducer creates a new kafka sync producer.

NewSyncProducerWithPrefix creates a new kafka sync producer.

Consumer for getting push requests.

Producer for producing push feedbacks to a kafka queue.

SyncProducer is a kafka producer using sarama lib.