vodfka

Vod-kakfa 🍸

Consummer producer wrapper and API a la Gin Gonic for kakfa

Getting Started

Import the module into your project

go get https://github.com/chefcookit/vod-kafka

1. In you main() function, you should first configure your instance.
2. Add your consumers
3. The last line of code in your main() function should be vodfka.Run() which will keep you server running.

vodfka.With(Config{
		KafkaBroker: "localhost:29092",
		Retries: 3,
		Logger: logger, // your app logger
	})

// declare consumers ....
vodfka.Consume("my-topic", "my-consumer-group", Handler.HandleEvent)

// This should be the last line of code in the main() function the server
// is not running any other service (HttpServer etc)
vodfka.Run()

Consumer exemple

// Asssign handler function in main function
vodfka.Consume("my-topic", "my-consumer-group", Handler.HandleEvent)

// Implement handler function in its own package
func (hdl *Handler) HandleEvent(c *kafka.Context) error {
	var event domain.Event
	err := c.BindJSON(&event)
	if err != nil {
		logger.Error("Could not consume Event")
		return err
	}
    // ... business logic
	return nil
}

Producer

// Initialise in main function then inject in dependencies
kafkaProducer := vodfka.GetProducer()

// This should be implemented in service layer
topic := "my-event-started"
key := "my unique key"

event := Event{
    BatchId:     batchId,
    PackageDate: packageDate,
}

if err := kafkaProducer.SendJSON(topic, key, event); err != nil {
    // ... handle error
}