Гость
Целевая тема:
Создать новую тему:
Автор:
Форумы / Java [игнор отключен] [закрыт для гостей] / kafka consumer не принимает сообщения после перезапуска / 2 сообщений из 2, страница 1 из 1
05.12.2018, 19:48
    #39743090
and)
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
kafka consumer не принимает сообщения после перезапуска
Привет

1) кафка запущена локально одна штука
2) cоздал топик --replication-factor 1 --partitions 1
3) настроил consumer/producer
4) посылаю сообщеня - все нормально доходят
5) убиваю консюмера
6) продолжаю посылать сообщеня
7) запускаю консюмера с той же самой группой и он ничего не принимает, kafka-consumer-groups.sh показывает "Warning: Consumer group .... is rebalancing"

вроде бы KAFKA-3859 тот самый случай, но он исправлен



может кто сталкивался?
...
Рейтинг: 0 / 0
05.12.2018, 21:52
    #39743157
and)
Участник
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
kafka consumer не принимает сообщения после перезапуска
and),

судя по всему где-то должна быть какая-то настройка на это, тк через несколько часов сообщения стали приходить
...
Рейтинг: 0 / 0
Форумы / Java [игнор отключен] [закрыт для гостей] / kafka consumer не принимает сообщения после перезапуска / 2 сообщений из 2, страница 1 из 1
Найденые пользователи ...
Разблокировать пользователей ...
Читали форум (0):
Пользователи онлайн (0):
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]