Kafka 基础实战

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