Kafka plain java

Using plain java to create a simple producer and consumer

Get started

1. Compile project by running the following command

mvn clean install assembly:single

the bundle file is demo.jar in target folder

2. Start kafka server

First, we need to start zookeeper

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

then start kafka server

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

Demos:

• Demo 1: multi-consumer instances with 1 topic and multi-partition
• Demo 2: Kafka cluster
• Demo 3: testing replication
• Demo 4: Kafka cluster in Docker
• Demo 5: data persistence

References

• Apache Kafka Tutorial
• What is Apache Kafka?
• Introduction
• Message Delivery Semantics