Потребительская проблема Кафки (получение с последним смещением)
Оцененное значение для settext было целым, поэтому он перешел к подключенному к нему ресурсу, но он не был найден, вы хотели установить текст так, чтобы он был строковым, чтобы преобразовать целое число в строку, добавив .toStringe или String.valueOf(int) решит вашу проблему!
1 ответ
Я не вижу его от потребителя, когда я поднимаюсь
Если вы запустите того же потребителя с тем же
group.id, он будет сброшен из ранее сохраненных разделов при условии, что ваши потребительские смещения были зафиксированы ранее.
Поведение по умолчанию для новых групп потребителей состоит в том, чтобы начинать с самого последнего смещения, и вам нужно установитьauto.offset.reset=earliestдля запуска с начала. Кроме того, смещения автоматически фиксируются по умолчанию, и рекомендуется отключить это, чтобы гарантировать, что каждое сообщение фактически обрабатывается хотя бы один раз, и выполнять фиксацию смещения вручную. Об этом есть много хорошей документации в KafkaConsumer JavaDoc .Если вы используете
console-consumer, то по умолчанию всегда используется самое последнее смещение до добавления--from-beginning, но вы также можете добавить--group <name>, чтобы присоединиться / возобновить группу потребителей.