Кафка потребитель перебалансирован, несмотря на разные групповые идентификаторы ⇐ Python

[Anonymous]

Я работаю над трубопроводом на основе Кафки, используя Python (Kafka-Python), где у меня есть два отдельных потребителя: < /p>

Код: Выделить всё

consumer.py

отслеживает факторы здоровья пользователя из темы aave-raw
→ использует group_id = "risk-dash-test"

Код: Выделить всё

aggregator.py

считывает как из Aave-raw , так и из-за риска-deltas
→ использует Group_id = "Risk-Aggreator"
Я подтвердил, что идентификаторы группы различны в обоих файлах.

Код: Выделить всё

Successfully joined group risk-dash-test
Updated partition assignment: [TopicPartition(topic='aave-raw', partition=0)]

Даже журналы агрегатора показывают, что он присоединяется к риску-тестированию, что неправильно. Файлы
[*] Добавлены отпечатки отладчиков (__file__, Group_id)
[*] Проверено, что я запускаю файл через python -m Pipeline.aggregator

Еще агрегатор inte graph-dash-dash-test, а не агрегатор код. Указано.>

Подробнее здесь: https://stackoverflow.com/questions/796 ... -group-ids