Documentation ¶
Overview ¶
Package helper implements general helper methods.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Confirmation ¶
Confirmation asks the user if he really intends to carry out the concerned action.
func ConnectKafkaClient ¶
ConnectKafkaClient makes a client connection to a Kafka cluster.
func RetrieveMetadata ¶
func RetrieveMetadata(broker *sarama.Broker) *sarama.MetadataResponse
RetrieveMetadata retrieve the metadata from the Kafka broker.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.