Documentation
¶
Index ¶
- func AsyncConsumeMessages(consumer async.Consumer, expectedMessageCount int) ([]string, error)
- func CreateProducerMessage(topic, message string) *sarama.ProducerMessage
- func CreateTopics(broker string, topics ...string) error
- func NewProducer(broker string) (sarama.SyncProducer, error)
- func SendMessages(broker string, messages ...*sarama.ProducerMessage) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AsyncConsumeMessages ¶
AsyncConsumeMessages from an async consumer.
func CreateProducerMessage ¶
func CreateProducerMessage(topic, message string) *sarama.ProducerMessage
CreateProducerMessage for a topic.
func CreateTopics ¶
CreateTopics helper function.
func NewProducer ¶
func NewProducer(broker string) (sarama.SyncProducer, error)
NewProducer helper function.
func SendMessages ¶
func SendMessages(broker string, messages ...*sarama.ProducerMessage) error
SendMessages to the broker.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.