zl程序教程

您现在的位置是:首页 >  系统

当前栏目

Linux 搭建 Kafka教程[通俗易懂]

LinuxKafka教程 通俗易懂 搭建
2023-06-13 09:14:31 时间

把kafka解压到linux去配置文件中配置环境

配置kafka文件内容

进入kafka/config目录修改server.properties 文件

修改broker.id= id里面的数值不可以重复

同时添加主机的ip 和端口

host.name=192.168.10.101
listeners=PLAINTEXT://192.168.10.101:9092

在下面找到log.dirs修改日志的地址

修改为我们三台机器ip地址

zookeeper.connect=localhost:2181

启动kafka先要三台机器都启动zookeeper集群

把kafka分发到另外几台机器中 环境也要进行分发

把另外几台机器的ip 和id修改成相应的ip即可

修改完后直接启动服务即可

kafka-server-start.sh kafka/config/server.properties &

kafka测试创建主题

kafka-topics.sh --create --zookeeper hadoop2:2181 --replication-factor 1 --partitions 1 --topic lol
查看当前所有列表
kafka-topics.sh --zookeeper hadoop3:2181 -list
启动生产者
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
启动消费者
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
删除主题
bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic test

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员栈长,转载请注明出处:https://javaforall.cn/181303.html原文链接:https://javaforall.cn