Skip to content
Simple example for reading and writing into Kafka
Java
Branch: master
Clone or download
Latest commit a82cca9 Sep 2, 2015
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
src/main Added example code Sep 2, 2015
.gitignore Initial commit Sep 2, 2015
LICENSE Initial commit Sep 2, 2015
README.md Create README.md Sep 2, 2015
pom.xml Added example code Sep 2, 2015

README.md

kafka-example

Simple example for reading and writing into Kafka

Set up Kafka

#get kafka
wget http://mirror.softaculous.com/apache//kafka/0.8.2.1/kafka_2.10-0.8.2.1.tgz
# unpack
tar xf kafka_2.10-0.8.2.1.tgz
cd kafka_2.10-0.8.2.1

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

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

# create topic “test”
 ./bin/kafka-topics.sh --create --topic test --zookeeper localhost:2181 --partitions 1 --replication-factor 1

# consume from the topic using the console producer
./bin/kafka-console-consumer.sh --topic test --zookeeper localhost:2181

# produce something into the topic (write something and hit enter)
./bin/kafka-console-producer.sh --topic test --broker-list localhost:9092

Watch this YouTube video to see how this code is working with Kafka: https://www.youtube.com/watch?v=7RPQUsy4qOM

You can’t perform that action at this time.