Введите краткое описание своих изменений
(Обязательно)
Minor changes are by default collapsed in the page history.
No changes
The page does not exist yet.
Failed to load changes
Версия от на
Leave Collaboration
Are you sure you want to leave the realtime collaboration and continue editing alone? The changes you save while editing alone will lead to merge conflicts with the changes auto-saved by the realtime editing session.
При первом подключении Consumer по умолчанию подсоединиться к концу топика (параметр AutoOffsetReset) и не прочитает сообщения, уже имеющиеся в топике. Задается параметром. (Подключиться к началу или к последнему сообщению)
Простой способ сбросить состояние - удалить содержимое папок:
Drive:\tmp\kafka-logs
Drive:\tmp\zookeeper
Если запросить группу сообщений и выполнить коммит последнего, то смещение установиться на позиции последнего элемента +1.
При первом подключении Consumer по умолчанию подсоединиться к концу топика (параметр AutoOffsetReset)
и не прочитает сообщения, уже имеющиеся в топике.
Задается параметром. (Подключиться к началу или к последнему сообщению)
kafka-topics.bat --bootstrap-server <server> --list
Консольный consumer
kafka-console-consumer.bat --bootstrap-server <server> --topic <topic> --from-beginning
Данные по ConsumerGroup(текущее смещение)
kafka-consumer-groups.bat --describe --group <ConsumerGroupId> --bootstrap-server <ip:port>
Удалить ConsumerGroup(смещения по группе)
kafka-consumer-groups.bat --bootstrap-server <server> --delete --group my-group