赛车不消费deliveryboy写的信息(Kafka·鲁比)

kiayqfof  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(400)

我有一个问题是为了使用zendesk的deliveryboy/racecar Package 器来处理Kafka事件。
我使用racecar消费事件,但是通过deliveryboy使用sidekiq计划的作业,以延迟的间隔将事件发送回以进行重新处理。
它工作了很多次,但从那时起,赛车已经停止消费这些重新处理的事件。
deliveryboy仍然确认它将消息附加到主题:

Sending 1 messages to b-4.sa-xxx.kafka.sa-east-1.amazonaws.com:9094 (node_id=4)
Opening connection to b-4.sa-xxx.kafka.sa-east-1.amazonaws.com:9094 with client id service_sidekiq...
Sending produce API request 1 to b-4.sa-xxx.kafka.sa-east-1.amazonaws.com:9094
Waiting for response 1 from b-4.sa-xxx.kafka.sa-east-1.amazonaws.com:9094
Received response 1 from b-4.sa-xxx.kafka.sa-east-1.amazonaws.com:9094
Successfully appended 1 messages to topic-normalized/7 on b-4.sa-xxx.kafka.sa-east-1.amazonaws.com:9094 (node_id=4)

但消费者并不接受这个活动。
我知道通过其他方式写在这个主题上的事件会被赛车所接收,似乎只有deliveryboy写的事件不会被它所消耗。
我改变了主意 client_id 送货员不同于 client_id 关于赛车(用一个写,用另一个听),但那没有帮助。
任何建议都将不胜感激。

gpfsuwkq

gpfsuwkq1#

结果是,我的日志级别设置不正确,并且无法看到副作用,因为我正在编写调试程序。
一切正常,用户错误。。

相关问题