kafka
Posted z_java_20150812
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了kafka相关的知识，希望对你有一定的参考价值。
安装jdk;
下载zookeepe并启动；
下载地址：
https://archive.apache.org/dist/zookeeper/zookeeper-3.5.8/apache-zookeeper-3.5.8-bin.tar.gz
将conf目录下的zoo_sample.cfg复制一份重命名为zoo.cfg。
启动：
下载kafka并启动；
下载地址：
https://archive.apache.org/dist/kafka/2.4.1/kafka_2.11-2.4.1.tgz
修改server.properties配置文件
启动：
创建一个topic;
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic myTopicName
查看topic
kafka-topics.bat --list --zookeeper localhost:2181
创建生产者
kafka-console-producer.bat --broker-list localhost:9092 --topic myTopicName
创建消费者
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic myTopicName
待解决：第四条消息，中文乱码了
以上是关于kafka的主要内容，如果未能解决你的问题，请参考以下文章
DouPHP去除Powered by DouPHP版权的方法