kafka-python

4зной

1ответ

No Brokers Доступна ошибка при попытке подключения к Kafka

У меня очень странная проблема при попытке локально подключиться к Kafka 0.10.0.0 с использованием клиента Python на CentOS. Мои варианты подключения довольно просто и по умолчанию: kafka_consumer = k

apache-kafka kafka-python 2016-08-02

---

1зной

3ответ

NoBrokersAvailable: NoBrokersAvailable-Kafka Error

Я уже начал изучать Кафку. Попытка основных операций над ним. Я задумался над тем, что касается «брокеров». Моя кафка работает, но когда я хочу создать раздел. from kafka import TopicPartition (ERROR

python apache-kafka kafka-consumer-api kafka-producer-api kafka-python 2016-08-09

---

1зной

1ответ

kafka-python raise kafka.errors.ConsumerFetchSizeTooSmall

Я пишу простой код в python 2.7, который использует обмен сообщениями из темы apache kafka. Код состоит в следующем: from kafka import SimpleConsumer,KafkaClient group = "my_group_test" client = Kaf

python python-2.7 apache-kafka kafka-python 2016-05-17

---

1зной

1ответ

Как написать искрообразованные данные обратно к брокеру kafka с помощью pyspark?

В моем приложении pyspark я намерен использовать потоки Spark как метод преобразования сообщений Кафки «в полете». Каждое такое сообщение изначально получено из определенной темы Кафки. Такое сообщени

python-2.7 pyspark spark-streaming kafka-producer-api kafka-python 2016-05-19

---