单元测试的时候,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回答
-
同学你好:
根据异常可以看出,kafka 连接超时了。如果是使用的本地 kafka,重启 kafka 即可。
如果是使用的虚拟机中的 kafka,可能需要做网络方面的配置。
欢迎来 QQ 群随时交流、讨论,也非常感谢同学的支持!
112019-06-12 -
lijikai1937
提问者
2019-06-12
一定要删除kafka配置文件里设置的路径,还有zookeeper设置的路径下的东西,不一样版本的kafka创建的topic不能共用的,记得删除。
00
相似问题
kafka如何保证每条消息只被消费一次
回答 2
投放优惠券调试问题
回答 1