package
0.6.6
Repository: https://github.com/cygy/ginamite.git
Documentation: pkg.go.dev

# Functions

Initialize : initializes the kafka producer/consumer.
NewClient : initialize a new Client struct.
Recover : recovers from a panic, use this function to the consumers.
SendMessageToTopic : sends a message to a topic.

# Variables

Main : main client of the application.

# Structs

Client : a kafka client.
MessageConsumer : a message consumer consumes messages from a queue 'topic' and executes 'action'.