单元测试的时候,kafka消费者看不到消息

来源:5-11 商户投放子系统 - 商户投放优惠券服务接口实现

lijikai1937

2019-06-11

单元测试可以通过,但是在消费者那里收不到消息,报错是下面这样的
org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for merchants-template-0

写回答

2回答

张勤一

2019-06-12

同学你好:

    根据异常可以看出,kafka 连接超时了。如果是使用的本地 kafka,重启 kafka 即可。

    如果是使用的虚拟机中的 kafka,可能需要做网络方面的配置。


    欢迎来 QQ 群随时交流、讨论,也非常感谢同学的支持!

1
1
lijikai1937
非常感谢!
2019-06-12
共1条回复

lijikai1937

提问者

2019-06-12

一定要删除kafka配置文件里设置的路径,还有zookeeper设置的路径下的东西,不一样版本的kafka创建的topic不能共用的,记得删除。

0
0

Java分布式后台开发 Spring Boot+Kafka+HBase

从零到一完整搭建企业级架构的通用卡包工程,让你迈到百度T4+ 。

886 学习 · 221 问题

查看课程