直接在Mac里运行,send message失败

来源:4-9 -Kafka Producer Java API编程

KeepFoolish的小白菜

2019-03-07

我是直接在Mac里运行代码:KafkaProperties类中的String ZK和BROKER_LIST处“192.168.199.111:2181” & “192.168.199.111:9092” 中的“192.168.199.111”应该改成“localhost” or “127.0.0.1” or “192.168.1.26” (后面两个都是在terminal里ifconfig里查出来的)。。这三个其实我都试过了,但是都会报出如下错误:
图片描述
KafkaProducer的35行是如下框中代码:
图片描述
这类的错误到底是ip地址写的不对还是我代码哪里抄的不对呐。。

写回答

2回答

Michael_PK

2019-03-07

代码哪里不对直接对比下git就知道了。IP那地方只要填上你的zk或者kafka的IP地址就行了,如果你本地配置了IP和hostname的对应关系也填写hostname也行呢,前提是你本地本地本地机器配置了映射关系。当然你本地到服务的网要通

0
1
KeepFoolish的小白菜
非常感谢!
2019-03-08
共1条回复

KeepFoolish的小白菜

提问者

2019-03-07

因为启动了相同名字的topic(hello_topic),需先kill再重新进行操作,或重新取名代码中的topic

0
1
T_w
同学,具体解释一下吗,我也是这个问题
2019-05-08
共1条回复

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

查看课程