后台启动：bin/kafka-server-start.sh config/server.properties > /dev/null 2>&1 &

启动生产者：bin/kafka-console-producer.sh --broker-list localhost:9092 --topic data

启动消费者：bin/kafka-console-consumer.sh --bootstrap-server localhost:2181 --from-beginning --topic data

创建topic：./bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic data --partitions 1 --replication-factor 1