Гоночная машина не использует сообщения, написанные DeliveryBoy (kafka-ruby)

Question

У меня есть вопрос, связанный с использованием оберток zendesk deliveryboy/racecar в тандеме для обработки событий Kafka.

Я потребляю события с помощью Racecar, но отправляю события обратно на повторную обработку с задержкой в ​​ту же тему через DeliveryBoy, используя запланированное задание Sidekiq.

Это сработало несколько раз, но с тех пор 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 (писать одним, слушать другим), но это не помогло.

Любой совет приветствуется.

Answer 1

В итоге у меня был неверно установлен уровень журнала, и я не смог увидеть побочные эффекты, так как писал для отладки.

Все работает как положено, ошибка пользователя..