输出kafka的topic接收不到数据

输出kafka的topic接收不到数据

没有任何报错,仔细核对过了topic的名称也没有错误,但是奇怪的是,输出topic无法接收到数据,监听输入topic,数据是可以正常接收的。调试结果如下:

https://img1.sycdn.imooc.com/climg/65961f4d0993a4f118200737.jpg

从调试信息,来看整个程序按道理是正确的,但是输出topic就是无法接收到数据,是为什么呢?通过java程序开启的kakfa消费者和linux控制台开启的消费者都接收不到输出topic的数据,输入topic监听是可以收到数据的,说明kafka集群没问题。百思不得其解后,完全复制了老师您课程里的代码进行了测试,同样是这种情况,实在想不明白是什么原因,也没有报错信息,并且在代码最后一步感觉生成的对象好像也没有问题,但是就是kafka消费者无法接收到数据


正在回答 回答被采纳积分+1

登陆购买课程后可参与讨论,去登陆

1回答
提问者 蒋昌魁 2024-01-04 11:31:45

老师,整出来了,反复比对了下两个生产者的区别,发现少了泛型,加上泛型后,结果就正常输出和接收了

https://img1.sycdn.imooc.com/climg/6596264809ca0a7812280635.jpg

https://img1.sycdn.imooc.com/climg/659626370983423612500799.jpg

  • 好的,解决了就好
    2024-01-04 15:11:05
  • 提问者 蒋昌魁 回复 徐老师 #2

    老师,之后修改代码后,又无法接收到信息了。进一步排查找到了最终的原因,原来是kafka节点宕机了一个。不过这反倒让我有新的疑问了,3个kafka节点,宕机了1个,还有2个是正常的,集群节点照理来说宕机1个,不会影响可用性吧?那为什么stu_clean节点无法接收到数据,而stu节点却不受影响呢?

    2024-01-04 17:15:10
  • 徐老师 回复 提问者 蒋昌魁 #3

    借助于cmak之类的web页面观察Kafka集群整体的状态、topic中的分区的分布情况,以及topic是否有副本

    2024-01-04 17:44:00
问题已解决,确定采纳
还有疑问,暂不采纳

恭喜解决一个难题,获得1积分~

来为老师/同学的回答评分吧

0 星
请稍等 ...
意见反馈 帮助中心 APP下载
官方微信

在线咨询

领取优惠

免费试听

领取大纲

扫描二维码,添加
你的专属老师