0

我有一个问题,旨在同时使用 zendesk 的送货员/赛车包装器来处理 Kafka 事件。

我使用 Racecar 使用事件,但使用 Sidekiq 计划作业通过 DeliveryBoy 以延迟的时间间隔将事件发回以重新处理到同一主题。

它工作了很多次,但从那以后,Racecar 已经停止使用这些重新处理事件。

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)

但消费者不接受该事件。

我知道通过其他方式写入主题的事件正在被 Racecar 接收,似乎唯一不消耗的事件是 DeliveryBoy 编写的事件。

我已经改变了client_idDeliveryBoy 与client_idRacecar 的不同(用一个写,另一个听),但这并没有帮助。

任何建议表示赞赏。

4

1 回答 1

0

结果是我的日志级别设置不正确,并且由于我正在编写调试文件而无法看到副作用。

一切都按预期工作,用户错误..

于 2020-08-06T06:08:14.110 回答