Documentation ¶
Overview ¶
Package kafka implements an eio producer and consumer for kafka.
You must import this package separately to make these available.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer struct { Args struct { // List of brokers to connect to Brokers []string // Name of the topic to read from. Topic string } // contains filtered or unexported fields }
Consumer implements a kafka consumer
type Producer ¶
type Producer struct { Args struct { // List of brokers to connect to Brokers []string // Name of the topic to push to. This is only necessary when not // creating a TopicProducer. Topic string } // contains filtered or unexported fields }
Producer implements a kafka producer
Click to show internal directories.
Click to hide internal directories.