Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Gomkafka ¶
func Gomkafka(config *KafkaConfig) (*sarama.Client, *sarama.SimpleProducer, error)
Gomkafka will Initialize a kafka client and producer based off of KafkaConfig.
Types ¶
type KafkaConfig ¶
KafkaConfig represents the required configuration settings to create a Kafka client to send requests to a topic in a Kafka cluster.
Click to show internal directories.
Click to hide internal directories.