导入：/usr/local/kafka/bin/kafka-console-producer.sh --broker-list 10.16.252.48:9092,10.16.252.49:9092,10.16.252.50:9092 --topic k8s_log_pl_old < /data/k8s_log_pl.txt
导出：/usr/local/kafka/bin/kafka-console-consumer.sh --zookeeper 10.16.252.48:2181,10.16.252.49:2181,10.16.252.50:2181 --topic k8s_log_pl --from-beginning > /data/k8s_log_pl.txt &
kafka增加分区：./kafka-topics.sh --alter --zookeeper 10.16.252.48:2181,10.16.252.49:2181,10.16.252.50:2181 --topic k8scs1_log_online --partitions 24
Kafka专为分布式高吞吐量系统而设计。 作为一个更传统的消息代理的替代品。 与其他消息传递系统相比，Kafka具有更好的吞吐量，内置分区，复制和固有的容错能力，这使得它非常适合大规模消息处理应用程序。
在实际使用中，kafka的不同版本协议也不完全一致，不是向下兼容的，使用时需特别注意，我这里使用的是0.9.0.1的版本。
本次安装的服务器为物理机3台: CPU：双Intel(R) Xeon(R) Silver 4110 CPU @ 2.10GHz 内存：128G配置 10块SAS HDD 1T盘做raid10，挂载到/data1。
| 主机名 | IP | 备注 |
|---|---|---|
| sh-saas-k8s-kafka-online-01 | 10.16.252.33 | zookeeper,kafka |
| sh-saas-k8s-kafka-online-02 | 10.16.252.39 | zookeeper,kafka |
| sh-saas-k8s-kafka-online-03 | 10.16.252.40 | zookeeper,kafka |
kafka需要用到zookeeper，所以我们需要先安装zookeeper。kafka及zookeeper都需要是JAVA语言开发，需要使用JDK，推荐1.8版本。
