Я получаю эту ошибку при создании KafkaProducer с пакетом kafka-python: [ERROR]...

Я использую kafka-python в проекте django. Инициализировал производителя в файле settings.py....

У меня есть функция без сервера, которая пытается отправить некоторые данные в kafka. Иногда это...

Я хочу получить список групп потребителей Kafka по темам в kafka-python, но не смог. Как я могу...

Новичок играет с Кафкой и AVRO. Я пытаюсь десериализовать сообщения AVRO в Python 3.7.3, используя...

Я пытаюсь получить оперативные данные из openweathermap.org API с помощью kafka Producer python....

Я использую Kafka v2.2, сейчас я подключаюсь к Consumer с моего сервера aiohttp, используя...

kafka-python 1.4.6 Python 3.7.3 debezium / kafka 0.9 Я использую kafka-python для настройки своей...

У нас есть приложение Python FLASK, в котором мы используем приложение Kafka Consumer, а Flask...

Env: services: zookeeper: image: wurstmeister/zookeeper ports: - 2181 kafka: image:...

На диаграмме выше показана текущая архитектура, которую я пытаюсь реализовать.В настоящее время я...

B1, B2, B3 - брокеры Уменьшите B2, B3 - теперь B1 становится лидером по темам Уменьшить B1...

Я установил Apache Kafka на сервере Ubuntu и протестировал его, выполнив первые пять шагов,...

Я пытаюсь опубликовать сообщения через python в теме kafka и получаю сообщение об ошибке. Я могу...

При самом первом потреблении мой потребитель потребляет одно и то же сообщение дважды, это...

Я новичок в клиенте kafka на python, мне нужна помощь, чтобы описать темы с помощью клиента. Мне...

Я хочу иметь возможность читать сообщения, приходящие в определенные разделы темы, а также...

Я установил экземпляр AWS EC2, работающий под управлением Apache Kafka 0.8 через образ Bitnami AMI

Я пытался повторить шаги, описанные в блоге . При попытке получить код Python Kafka Consumer и...

Я пытаюсь написать потребителя, использующего Kafka-Python, обеспечивающего семантику ровно один...

Это код на Python для написания простого производителя / потребителя: import json import logging...

Я делаю потоковую передачу данных через Твиттер от Кафки.Мне удалось передать данные и использовать...

Я довольно новичок в Python и только начинаю работать с Kafka, так что извините мою терминологию,...

Есть ли способ опубликовать сообщение для всех разделов?Я использую kafka-python == 1.4.3. Из...

У меня есть веб-приложение на основе Django, в которое я пытаюсь интегрировать Kafka с помощью этой...