Creating a kafka-cluster with monitoring tools setup in AWS. No support of SSL or ACLs.
Adapt ansible/inventories/aws/hosts according to your setup.
cd ansible
ansible-playbook -i inventories/aws/ cluster.yml
Name | |
---|---|
Kafka Brokers | kafka-1:9092,kafka-2:9092,kafka-3:9092 |
Either ssh into one of your machines where Kafka is installed or install Kafka CLI tools locally.
kafka-topics.sh --zookeeper kafka-1:2181 --create --replication-factor 1 --partitions 4 --topic sample
kafka-console-producer.sh --broker-list kafka-1:9092,kafka-3:9092 --topic sample
Hey, is Kafka up and running?
kafka-console-consumer.sh --bootstrap-server kafka-1:9092,kafka-3:9092 --topic sample --from-beginning
Hey, is Kafka up and running?
kafka-producer-perf-test.sh --producer-props bootstrap.servers="kafka-1:9092,kafka-2:9092,kafka-3:9092" --topic sample --num-records 2000 --throughput 100 --record-size 256