創建一個2個分區,3個副本的topic,名字叫first
kafka-topics.sh --create --zookeeper datanode1:2181 --partitions 2 --replication-factor 3 --topic first
生產者發送消息順序發送:
消費者接收到消息是沒有順序的
/kafka-console-consumer.sh --bootstrap-server datanode1:9092 --topic first --from-beginning