1、准备环境
1.1安装jdk（省略）
2.2安装zookeeper集群（省略）
2、下载安装包并解压
# wget https://archive.apache.org/dist/kafka/1.1.0/kafka_2.11-1.1.0.tgz # tar -xzf kafka_2.11-1.1.0.tgz # cd kafka_2.11-1.1.0
3、修改配置文件 分别在128，129，130上修改
broker.id=0 每台服务器的broker.id都不能相同 #hostname host.name=192.168.0.128 #设置zookeeper的连接端口 zookeeper.connect=192.168.0.128:2181,192.168.0.129:2181,192.168.0.130:2181
4、启动 三台都要启动
sh bin/kafka-server-start.sh -daemon config/server.properties
5、创建主题
sh bin/kafka-topics.sh --create --zookeeper 192.168.0.128:2181 --replication-factor 2 --partitions 1 --topic houge
##查看主题
sh bin/kafka-topics.sh --list --zookeeper 192.168.0.128:2181
##查看主题详细信息
sh bin/kafka-topic.sh --describe --zookeeper 192.168.0.128:2181 --topic houge
6、发送消息
sh bin/kafka-console-producer.sh --broker-list 192.168.0.128:9092 --topic houge
>
>
>
7、消费消息
sh bin/kafka-console-consumer.sh --zookeeper 192.168.0.128:2181 --topic houge --from-beginning
<style></style>
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。