Simple producers and consumers for Apache Kafka
- Visit the Apache Kafka download page to install the most recent version (1.0.0 as of this writing).
- Extract the binaries into a software/kafka folder. For the current version, it's software/kafka_2.12-1.0.0.
- Change your current directory to point to the new folder.
- Run Apache ZooKeeper and Kafka:
bin/zookeeper-server-start.sh config/zookeeper.properties
bin/kafka-server-start.sh config/server.properties
- Create a test topic to use for testing:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic modulab
git clone https://github.com/alfonsserra/kafka-test.git
cd kafka-test
mvn compile assembly:single