Утверждение не выполнено: (self->u.Consumer.rkqu) для слитного Python Kafka ⇐ Python

[Anonymous]

Попробуйте пример слитной базы Kafka
from confluent_kafka import Consumer

c = Consumer({
'bootstrap.servers': 'localhost:9092',
'group.id': None,
'auto.offset.reset': 'earliest'
})

c.subscribe(['my_topic'])

while True:
msg = c.poll(1.0)

if msg is None:
continue
if msg.error():
print("Consumer error: {}".format(msg.error()))
continue

print('Received message: {}'.format(msg.value().decode('utf-8')))

c.close()

получил
Assertion failed: (self->u.Consumer.rkqu), function Consumer_init, file Consumer.c, line 1668

Что это может означать?
Версия Python
Python 3.10.1

ОС:
macOS 15.6.1


Подробнее здесь: https://stackoverflow.com/questions/797 ... thon-kafka