Racecar 不使用 DeliveryBoy 写的消息 (kafka-ruby)

Question

我有一个问题是针对串联使用 zendesk 的 deliveryboy/racecar 包装器来处理 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 编写的事件。

我已经更改了 DeliveryBoy 的 client_id 以不同于 Racecar 的 client_id（用一个写，用另一个听）但这没有帮助。

如有任何建议，我们将不胜感激。

Answer 1

结果是我的日志级别设置不正确，无法见证 side-effects 因为我正在写调试。

一切正常，用户错误..

Racecar 不使用 DeliveryBoy 写的消息 (kafka-ruby)

Racecar not consuming messages written by DeliveryBoy (kafka-ruby)

ruby-on-rails

apache-kafka

sidekiq

ruby-kafka