前提：

        一个正常的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

        导出成功，查看内容是否正确

 数据导出成功！