kafka-topics.sh --create --zookeeper IP:PORT,IP:PORT,IP:PORT --replication-factor 2 --partitions 2 --topic test
kafka-console-producer.sh --broker-list IP:PORT,IP:PORT,IP:PORT --topic test
kafka-console-consumer.sh --bootstrap-server IP:PORT,IP:PORT,IP:PORT --from-beginning --topic test