Фильтр репликатора для уже использованных сообщений - PullRequest
0 голосов
/ 03 мая 2019

Почему слитый репликатор реплицирует уже использованные сообщения? Существует много вариантов использования, когда сообщение по теме не требуется после использования. Разве это не хорошая идея, чтобы отфильтровать уже использованные сообщения (при условии, что есть какой-то реестр потребителей)

1 Ответ

0 голосов
/ 09 июня 2019

Он не должен реплицировать уже использованные сообщения, если корректно возвращаются смещения для группы потребителей репликатора

Сообщения, используемые вашими другими процессами, не удаляют их из темы Kafka, а когда Replicator входит в другую группу потребителей, он не будет знать, что потребляется

...