Apache Kafka Recipes

This project provides sample recipes for usage of Apache Kafka Message broker.

Requirements:

• Apache Maven version 3

• Apache Kafka 0.10.1.1

• JDK 8

Quickstart:

Installation:

Clone the repository using command

git clone git://github.com/aparnachaudhary/apache-kafka-recipes.git

Building:

To build, issue this from the command line:

mvn clean install

Setup Kafka

To execute the samples, we need to first get ZooKeeper and Kafka up and running.

• Start ZooKeeper

$KAFKA_HOME/bin/zookeeper-server-start.sh $KAFKA_HOME/config/zookeeper.properties

• Start Kafka

$KAFKA_HOME/bin/kafka-server-start.sh $KAFKA_HOME/config/server.properties

Examples Recipes

• Recipe-01 - Dispatch message to Kafka Topic

• Recipe-02 - Receive message from Kafka Topic

• Recipe-03 - Dispatch Avro message to Kafka Topic

• Recipe-04 - Receive Avro message from Kafka Topic

• Recipe-05 - Custom partition assignment

• Recipe-06 - Spring Boot Kafka Message Sender/Receiver

Feedback:

Please feel free to raise bug reports or feature requests here Issues.

Licensing and Copyright:

The project is licensed under the Apache License, Version 2.0