创建主题成功:
但是启动控制台消费者就会失败:
Java代码启动消费者也会报错:
kafka版本是
,初学kafka,百度这些异常也找不到问题,实在不知道怎么办了,求助啊!
发表于 2018-12-04
昵称
0 声望
这家伙太懒，什么都没留下
我是在网上看视频学的,网上的kafka版本在启动消费者时候,是用zookeeper,但是我用的版本只能用broker-servers,但是不会到怎么设置,就一直报错啊,还有java代码报错实在看不懂,百度都找不到
先把命令形式的调通吧。broker-servers对应的是kafka的9092端口
我在命令上master,slave1,slave后都加上端口之后不报错了倒是
我java的producer代码主方法运行之后,一直处于阻塞状态,是从官网api复制过来的,很奇怪
命令行的好了,提供消费都好了,就是代码不知道怎么回事,基本上都是官网的api
不报错，能正常生产和消费了吗？
嗯呢 控制台的可以了,现在就java代码有问题. 一个是生产方 main启动后会一直阻塞,一个是消费方报我no entry found 百度也百度不出来问题, 代码都是从官网api复制的
额，你在server.properties配置listeners了吗？
没有呀,我看网上视频也没有配置; 就是简单的控制台运行消费端,然后java代码运行生产者,结果是 生产者一直阻塞,消费者那边没有接收到消息
在在server.properties里配置listeners，就好了。
弄好了,java这边生产,命令行接收现在好了, 导致生产一直阻塞的原因,我百度偶尔看见了
说的是,生产者代码里put设置bootstrap-servers那个地址只能host/port格式, 我用的是 ip/port就不行 ,好像是不能识别ip,只能识别hosts文件对应映射
消费者的java代码也好了,就是我上面贴的代码,然后ip改成hosts的映射,改成master:9092,slave1:9092,slave2:9092,就好了,ip不行
谢谢了哈
你的答案