NewMessage returns a binding.Message that holds the provided kafka message components.

NewMessageFromConsumerMessage 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.

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

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

NewSenderFromSyncProducer returns a binding.Sender that sends messages to a specific topic using sarama.SyncProducer.

WithMessageKey allows to set the key used when sending the producer message.

WriteProducerMessage fills 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.

ProtocolOptionFunc is the type of kafka_sarama.Protocol options.

SenderOptionFunc is the type of kafka_sarama.Sender options.