Потребитель Kafka возвращается пустым на второй звонок

Question

Я вставляю запись производителю Kafka и затем вызываю потребителя, который возвращает вставленный элемент (и ранее вставленные элементы), затем я снова вызываю клиента (не вставляя новую запись с производителем), потребитель не возвращает никаких записей.

Насколько я знаю, запись должна остаться в теме. Я понятия не имею, как установить подтверждение в свойствах false. Этот вопрос связан с подтверждением?

Answer 1

Потребитель будет получать только «новые» сообщения. Если вы ранее читали до конца темы и ничего нового нет, вы ничего не получите.

Если вы хотите снова прочитать с начала темы, вам нужно «перемотать» потребителя (или создать новый).

Понятия не имею, как установить в свойствах подтверждение «ложь» (связана ли эта проблема с подтверждением?)

Если вы используете группы потребителей, смещения для потребителя (насколько он читается для каждого раздела темы) будут храниться в Kafka (или Zookeeper для более старых версий). Вы можете контролировать это, подтверждая (или нет) получение сообщений. Однако это действует только при перезапуске потребителя, а не для уже запущенного экземпляра.

Если вы не используете группы потребителей, это отслеживание смещений выполняется исключительно внутри самого экземпляра потребителя.