kafkapoc

Exploring the innards of Sarama library for Kafka. Language used is Golang

#Usage:

To run Kafka producer

go run main.go producer --topic TOPICNAME --message MESSAGESTRING

Note : List of topics is specified in the config file. The topic name used should be from the list.

To run Kafka consumer

go run main.go consumer

#Todo:

1. Modify and test various partitioning schemes
2. Hands on with Sharding
3. General Sarama optimizations