Когда я пытаюсь запустить hello world ( опубликовано здесь ) для confluent-kafka==1.0.1, мой...

Мне интересно, как добавить свойства к AvroProducer в python. Вот код, который я пробовал, вы...

from confluent_kafka import Producer p = Producer({'bootstrap.servers':...

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

Я подключил Кафку к MySQL.Тема содержит данные в формате AVRO.Теперь я хочу преобразовать эти...

Я использую пакет confluent_kafka для работы с Kafka. Я создаю тему таким образом: from...

Является ли confluent kafka API для потоковой передачи, группировки и агрегирования на языке Python

Я реализовал потребитель Kafka, используя .net core 2.1 с Confluent.Kafka SDK (C #). Функция опроса...

Мне нужно, чтобы мой потребитель потреблял определенное количество TopicPartitionOffset(here from...

Я использую библиотеку Python Confluent kafka для приема сообщений, я хочу получить несколько...

В библиотеке Confluent Kafka (в данном случае версии python) есть метод продукта, который принимает...

Попытка использовать confluent_kafka.AvroConsumer для получения сообщений с заданной отметкой...

У меня проблемы с использованием данного смещения с использованием python, в Java я реализовал...

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

Я немного новичок в Python, но мне нужно установить библиотеку на Linux-машине, я использую Python...

Conflunet Kafka 5.0.0 была установлена ​​на AWS EC2 с публичным IP-адресом, скажем, 54.XX.XX.XX...

Описание Я пытался проверить правильность фрагмента данных, которые я посылаю Кафке.Когда я пытался...

Я установил confluent_kafka: /home/ed/anaconda3/bin/python >>> import confluent_kafka не...