kafka-python

0зной

1ответ

python kafka: как сделать каждый msg потребляемым только один раз по группе с начала

Я использую Kafka consumer здесь (версия 1.3.1). То, что я для того чтобы достигнуть: Есть 10 разделов. каждая секция начинается со смещения 0. Существует группа потребителей (1,2,3, например). Иногда

0зной

3ответ

Kafka Consumer не получал сообщений от своего продюсера

следующее мое кодирование python для производителя kafka, я не уверен, что сообщения могут быть опубликованы в Kafka Broker или нет. Потому что потребительская сторона не получает никаких сообщений. М

1зной

2ответ

Проблемы с кодированием/форматированием с помощью библиотеки python kafka

Я пытался использовать библиотеку python kafka немного и не могу заставить продюсера работать. После небольшого исследования я узнал, что kafka отправляет (и, как я полагаю, ожидает, также) дополнител

7зной

1ответ

Как подписаться на список нескольких шаблонов шаблонов кафки с использованием kafka-python?

Я подписываюсь на Kafka, используя шаблон с шаблоном, как показано ниже. Подстановочный знак представляет собой динамический идентификатор клиента. consumer.subscribe(pattern='customer.*.validations')

0зной

1ответ

Одиночный производитель для нескольких потребителей (одна и та же группа потребителей)

Я попытался до отправки сообщения от одного производителя до 2-х разных потребителей с РАЗНОЕ группа потребителей. В результате оба потребителя могут прочитать полное сообщение (оба потребителя получа

1зной

1ответ

kafka-python потребительские ошибки

Я довольно новичок в kafka и kafka-python. После установки kafka-python я попробовал наивную реализацию кода пользователя отсюда. http://kafka-python.readthedocs.io/en/master/usage.html Я написал код

0зной

1ответ

Как объединить два DStreams (pyspark)?

У меня есть поток кафки, входящий в тему ввода. Это код, который я написал для принятия потока кафки. conf = SparkConf().setAppName(appname) sc = SparkContext(conf=conf) ssc = StreamingContext(sc)