一个正常的zookeeper环境和kafka环境：Kafka -- linux下简单实用自带脚本启动测试_DGH2430284817的博客-CSDN博客
测试导入数据：进入到kafka下载目录
创建一个文件producer.txt，随便初始化一些数据
创建一个topic ， testport
bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic testport --partitions 1 --replication-factor 1
消费者监听topic ， testport
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testport --from-beginning
另开一个终端窗口，用生产者导入文件producer.txt数据进kafka的 topic， testport ，查看效果
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testport < logs/producer.txt
导入数据成功！
测试导出数据：进入到kafka下载目录
导出数据到文件output.txt 到logs 目录下
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testport --from-beginning > logs/output.txt
导出成功，查看内容是否正确
数据导出成功！
