在线等！spark streaming整合kafka 无法消费到topic数据

m331283153 · 发表于 2017-8-18 11:27:54

你数据是一直在发布的吗，"auto.offset.reset" 这个参数设置为"latest"的时候是指从最新消息开始消费，设置为“earliest”的时候是从头开始消费，如果你消息不是一直在发布的话就把这个参数换成earliest

bottlevil · 发表于 2018-7-4 14:23:12

醉半城发表于 2017-7-13 17:15
发现，清除所有topic后，重新测试就OK了。。。。

楼主，请问您说的清除所有topic是什么意思
我也遇到和你一样的问题，求解答

s060403072 · 发表于 2018-7-4 15:15:16

bottlevil 发表于 2018-7-4 14:23
楼主，请问您说的清除所有topic是什么意思
我也遇到和你一样的问题，求解答

删除topic，如删除test topic如下
[mw_shl_code=bash,true].\kafka-topics.bat --delete --zookeeper localhost:2181 --topic test
[/mw_shl_code]

图文精华