|
|
|
@ -5,10 +5,12 @@ Using Vagrant to get up and running.
@@ -5,10 +5,12 @@ Using Vagrant to get up and running.
|
|
|
|
|
1) Install Virtual Box [https://www.virtualbox.org/](https://www.virtualbox.org/) |
|
|
|
|
2) Install Vagrant >= 1.6.4 [https://www.vagrantup.com/](https://www.vagrantup.com/) |
|
|
|
|
3) Install Vagrant Plugins: |
|
|
|
|
``` |
|
|
|
|
$ vagrant plugin install vagrant-hostmanager |
|
|
|
|
|
|
|
|
|
$ vagrant plugin install vagrant-hostmanager |
|
|
|
|
# Optional |
|
|
|
|
$ vagrant plugin install vagrant-cachier # Caches & shares package downloads across VMs |
|
|
|
|
# Optional, to caches & shares package downloads across VMs |
|
|
|
|
$ vagrant plugin install vagrant-cachier |
|
|
|
|
``` |
|
|
|
|
|
|
|
|
|
In the main Kafka folder, do a normal Kafka build: |
|
|
|
|
|
|
|
|
@ -48,13 +50,11 @@ To log into one of the machines:
@@ -48,13 +50,11 @@ To log into one of the machines:
|
|
|
|
|
|
|
|
|
|
vagrant ssh <machineName> |
|
|
|
|
|
|
|
|
|
You can access the brokers and zookeeper by their IP or hostname, e.g. |
|
|
|
|
You can access the brokers by their IP or hostname, e.g. |
|
|
|
|
|
|
|
|
|
# Specify ZooKeeper node 1 by it's IP: 192.168.50.11 |
|
|
|
|
bin/kafka-topics.sh --create --zookeeper 192.168.50.11:2181 --replication-factor 3 --partitions 1 --topic sandbox |
|
|
|
|
|
|
|
|
|
# Specify brokers by their hostnames: broker1, broker2, broker3 |
|
|
|
|
bin/kafka-console-producer.sh --broker-list broker1:9092,broker2:9092,broker3:9092 --topic sandbox |
|
|
|
|
# Specify brokers by their hostnames: broker1, broker2, broker3 (or just one of them) |
|
|
|
|
bin/kafka-topics.sh --create --bootstrap-server broker1:9092 --replication-factor 3 --partitions 1 --topic sandbox |
|
|
|
|
bin/kafka-console-producer.sh --bootstrap-server broker1:9092,broker2:9092,broker3:9092 --topic sandbox |
|
|
|
|
|
|
|
|
|
# Specify brokers by their IP: 192.168.50.51, 192.168.50.52, 192.168.50.53 |
|
|
|
|
bin/kafka-console-consumer.sh --bootstrap-server 192.168.50.51:9092,192.168.50.52:9092,192.168.50.53:9092 --topic sandbox --from-beginning |
|
|
|
|