Вопросы по теме '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 просмотров
schedule
08.05.2023
Как кафка распознает группу потребителей?
У меня есть этот код для создания потребителя, сбалансированного в 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