Returns a binding.Message that holds the provided kafka message components.

Returns a binding.Message that holds the provided ConsumerMessage.

NewProtocol creates a new kafka transport.

NewProtocolFromClient creates a new kafka transport starting from a sarama.Client.

NewReceiver creates a Receiver which implements sarama.ConsumerGroupHandler The sarama.ConsumerGroup must be started invoking.

Returns a binding.Sender that sends messages to a specific receiverTopic using sarama.SyncProducer.

Returns a binding.Sender that sends messages to a specific receiverTopic using sarama.SyncProducer.

Add a transformer, which Sender uses while encoding a binding.Message to a sarama.ProducerMessage.

Fill the provided producerMessage with the message m.

Message holds a Kafka Message.

Receiver which implements sarama.ConsumerGroupHandler After the first invocation of Receiver.Receive(), the sarama.ConsumerGroup is created and started.

Sender implements binding.Sender that sends messages to a specific receiverTopic using sarama.SyncProducer.

kafka_sarama.Protocol options.

kafka_sarama.Sender options.