Quick up and running using Scala for Apache Kafka
Use Vagrant to get up and running.
- Install Vagrant http://www.vagrantup.com/
- Install Virtual Box https://www.virtualbox.org/
In the main kafka folder
- vagrant up
- ./sbt test
once this is done
- Zookeeper will be running 192.168.86.5
- Broker 1 on 192.168.86.10
- All the tests in src/test/scala/* should pass
If you want you can login to the machines using vagrant ssh but you don't need to.
You can access the brokers and zookeeper by their IP from your local without having to go into vm.
e.g.
bin/kafka-console-producer.sh --broker-list 192.168.86.10:9092 --topic
bin/kafka-console-consumer.sh --zookeeper 192.168.86.5:2181 --topic --from-beginning