Я создал кафку с 3 брокерами с 3 коэффициентами репликации. Я пытался работать с kafka, постоянно генерируя сообщения, используя 3 производителя (та же тема), также я использую 3 потребителя для чтения сообщений.
Затем для проверки отказоустойчивости я убил одного брокера.
Мы можем убедиться, что сторона-производитель не потеряет сообщение, добавив
property "acks=all"
Eg : props.put("acks","all")
Но как я могу гарантировать, что потребитель читает все сообщения, не теряя ни одного сообщения
Любая помощь, которую вы можете оказать, будет принята с благодарностью.