глупый, короче, партиции это ведь не копии, я правильно понимаю? или копии?
Смотрю в Кафдропе, вижу полностью идентичные сообщения для 3 партиций одного и того же топика.
Делаю тогда вот так...
kafkacat -C -b my-first-broker:9092 -t my-topic -o -5 -e
Он мне выдает 15 строк - я так понимаю 3 партиции * 5 сообщений, и там в числе прочего...
{"timestamp":"2022-12-08T09:56:32.19495","code":"my-message#1"}
{"timestamp":"2022-12-08T09:56:32.19495","code":"my-message#2"}
{"timestamp":"2022-12-08T09:56:32.19495","code":"my-message#3"}
то есть в Кафдропе никаких этих #1, #2, #3, в кафкакэте есть. Как это можно объяснить?
my-message - это идентичное содержимое
не копии, но там есть реплики, с которыми напрямую никак не взаимодействуешь
и фактор репликации - это из другой оперы, верно?
в кафкакете через шаблон распечатайте номер партиции и оффсета и сравните с кафкадропом возможно ваш продюсер дублит ретраями из-за ошибок, тогда надо идемпотентность включить и maxinflightrequests в 1
спасибо, покопаю
Обсуждают сегодня