我有一个问题,旨在同时使用 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_id
DeliveryBoy 与client_id
Racecar 的不同(用一个写,另一个听),但这并没有帮助。
任何建议表示赞赏。