Описание тега kafka-rebalance
2
ответа
Поведение потребителя Кафки, когда один потребитель падает / падает
В моих темах 115 разделов и около 130 потребителей. Я ожидаю, что 115 потребителей в активном состоянии (назначение 1 к 1) и остальные 15 потребителей в состоянии ожидания. Несколько раз я наблюдал высокую память и JVM в зависшем состоянии, из-за че…
30 ноя '18 в 05:56
1
ответ
Kafka Разделение Ребаланс
Давайте предположим, что группа потребителей, имеющая 5 потребителей, подписывается на какую-то тему, которая имеет 10 разделов. Теперь, если еще 10 разделов будут добавлены к той же теме. Это вызывает перебалансировки. Почему kafka переназначает ра…
02 фев '19 в 09:19
0
ответов
Изменение баланса потребителей Kafka и его влияние
Я новичок в Kafka и пытаюсь создать библиотеку-обертку на Java и Go (использует Confluent/Kafka-Go) для внутреннего использования Kafka. Для моего варианта использования CommitSync является критически важным шагом, и мы должны выполнять чтение тольк…
18 мар '19 в 02:30
0
ответов
Кафка: Как получить предыдущие разделы для потребителя после ребалансировки
У меня есть тема Кафки gbtopic с 12 перегородками и группой потребителей gbconsumers с тремя потребителями C1, C2, C3, подписавшимися на эту тему. Когда все потребители запущены, каждому потребителю выделяется 4 раздела. Тогда я остановил потребител…
21 июн '19 в 11:43