Вопросы по теме 'pykafka'

Как заставить kafka-python или pykafka работать как асинхронный производитель с uwsgi и gevent?
Мой стек uwsgi с gevents. Я пытаюсь обернуть свои конечные точки API декоратором, чтобы отправить все данные запроса (url, метод, тело и ответ) в тему кафки, но это не работает. Моя теория заключается в том, что я использую gevents и пытаюсь...
5648 просмотров
schedule 10.06.2022

Роль потребителя кафки, отдельного сервиса или компонента Django?
Я разрабатываю аналитику веб-журнала. И я нашел архитектора с Django (Back-end & Front-end) + kafka + spark. Я также нашел ту же систему по этой ссылке: http://thevivekpandey.github.io/posts/2017-09-19-high-velocity-data-ingestion.html с...
3510 просмотров

Как кафка распознает группу потребителей?
У меня есть этот код для создания потребителя, сбалансированного в pykafka: consumer = topic.get_balanced_consumer(consumer_group='Testing',auto_commit_enable=True,zookeeper_connect='amsmgmt002:2181,nas5:2181,amsdblx006:2181') Как состояние...
72 просмотров
schedule 15.07.2023