大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。
Jetbrains全系列IDE稳定放心使用
把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
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/181303.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...