apache-kafka

1зной

2ответ

Kafka Producer Consumer API Issue

Я использую Kafka v0.10.0.0 и создал Продюсер & Потребительский Java-код. Но код застрял на производителю. Без каких-либо исключений в журналах. Может ли кто-нибудь помочь. Заранее спасибо. Я использу

apache-kafka kafka-consumer-api kafka-producer-api 2017-01-19

---

0зной

1ответ

, когда количество сообщений достигает максимального значения retention.bytes, kafka удалит сообщения, смещение будет сброшено до нуля?

Я новичок в kafka, когда мы используем kafka, мы можем установить retention.bytes. скажем, мы установили 1GB, если количество сообщений достигнет 1 ГБ, kafka удалит сообщения. Я хочу спросить, что сме

apache-kafka consumer 2017-01-19

---

3зной

1ответ

Плохая работа с функцией окна в потоковой работе

Я использую Spark 2.0.2, Kafka 0.10.1 и интеграцию с искрообразованием-кафкой-0-8. Я хочу сделать следующее: Я извлекаю функции в потоковой работе из соединений NetFlow, а не применяю записи к k-образ

apache-spark apache-kafka apache-spark-sql spark-streaming window-functions 2017-01-19

---

3зной

2ответ

Как начать Zookeeper, а затем Kafka?

Я начинаю с Confluent Kafka, которому требуется запустить Zookeeper (zookeeper-server-start /etc/kafka/zookeeper.properties), а затем Kafka (kafka-server-start /etc/kafka/server.properties). Я пишу сц

apache-kafka apache-zookeeper confluent-kafka 2017-01-19

---