kafka-python

0зной

1ответ

pykafka не может подключиться Кафка брокера

Когда я использую pykafka для подключения kafka кластера с помощью следующего кода: from pykafka import KafkaClient client = KafkaClient(hosts="10.0.0.101:9092") я получил исключение следующим обра

apache-kafka kafka-python 2016-01-21

---

2зной

2ответ

Фляга - Вытягивание живого потока данных кафки - Интеграция Kafka с колбой Python

Этот проект предназначен для исполнения real time search engine - log analysis. У меня есть данные о потоке в реальном времени от обработки искры до Кафки. Теперь с выходом Кафки, я хочу get the data

python flask socket.io flask-socketio kafka-python 2016-02-05

---

2зной

2ответ

Как использовать кафку на торнадо?

Я пытаюсь сделать простое приложение для чата с использованием торнадо на основе this Но также я хочу использовать kafka для хранения сообщений. Как я могу это сделать? Теперь я использовал this, чтоб

python tornado apache-kafka kafka-python 2016-02-12

---

1зной

1ответ

Публикация определенного раздела темы с использованием pykafka

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

python apache-kafka producer kafka-python message-bus 2016-02-18

---