harshach/kafka-examples

kafka consumer/producer examples

This application consumes messages from kafka topic. Make sure Kafka and zookeper are up and running on the machine we want to run kafka consumer.

Instructions for Kafka setup : http://kafka.apache.org/documentation.html#quickstart

Build the Jar : gradle clean build fatjar -x test

Run the application :

java -jar [jarForApplication] [topicName] [groupName] [brokerHostAndPort] [offset]

We need to pass 4 command line arguements : topicName, groupName, brokerHostAndPort and Offset to start the application.

Ex : java -jar build/9984d94/kafka-consumer-9984d94-all-1.0-SNAPSHOT.jar test-topic group1 localhost:9092 100

After you start the application, you will see the current offset and updated offset. You can type exit anytime to quit the consumer.