apache-kafka

2зной

1ответ

Неправильный вывод при создании DataFrame

Я пытаюсь передать данные из темы kafka с помощью приложения scala. Я могу получить данные из этой темы, но как создать из нее кадр данных? Вот данные (в строке, формат строки) { "action": "AppEv

dataframe apache-kafka spark-streaming 2016-12-19

---

0зной

1ответ

Почему этот потребитель (работающий на сервлете) не получает сообщений из темы кафки?

Я установил kafka-consumer на моем сервлете. Я прочитал из моей темы kafka и хочу напечатать последнее значение с помощью doGet-метода сервлета. Но если я посылаю doGet я просто получить «нулевой» наз

java servlets apache-kafka consumer 2016-12-19

---

0зной

1ответ

kafka-topics.sh --describe ничего не возвращают

Я запускаю кластер kafka, состоящий из 3 узлов. Один из узлов разбились, и он вел себя странно с тех пор ... Ниже не возвращает ничего о неисправном узле: kafka-topics.sh --describe --zookeeper mynode

apache-kafka 2016-12-19

---

1зной

1ответ

Spark Structured Streaming

Как включить несколько потоковых SQL-запросов, которые будут выполняться в потоке Kafka из одного задания. Является ли структурированная потоковая передача надежным способом продвижения вперед. Наприм

apache-spark apache-kafka structured-streaming 2016-12-19

---

-2зной

1ответ

Искра 2.0.2 ClassNotFoundException: org.apache.kafka.clients.consumer.Consumer

Ниже мой pom.xml. Я строю банку с оттенком maven. Я очень уверен в том, что org.apache.kafka.clients.consumer.Consumer включен в мою банку uber. Также я положил kafka-clients-0.10.1.0.jar в искру spar

maven apache-spark apache-kafka classnotfound 2016-12-20

---

0зной

1ответ

Использование класса KafkaConsumer?

Я учусь KafkaConsumer и есть вопрос в строке 3 1.from kafka import KafkaConsumer 2.consumer = KafkaConsumer(arglist) 3.for message in consumer Я знаю, что «для ... в ...» заявлении. Этот цикл for

python apache-kafka 2016-12-20

---

0зной

2ответ

Apache Flink чтение Avro байт [] от Кафки

В рассматривающих примерах, которые я вижу много это: FlinkKafkaConsumer08<Event> kafkaConsumer = new FlinkKafkaConsumer08<>("myavrotopic", avroSchema, properties); я вижу, что они здесь уже знают с

java stream apache-kafka apache-flink 2016-12-21

---

0зной

1ответ

Выполнение примера kafka-stream с помощью eclipse, не выполняется с помощью UnsatisfiedLinkError для librocksdbjni.dll (не удается найти зависимость)

Я пытаюсь запустить пример wordcount из kafka-stream с Eclipse IDE, но получаю следующую ошибку: Я добавил 0.10. 1.0 kafka-client и 0.10.1.0 kafka-stream как зависимость в моем файле pom. Я также пров

java eclipse apache-kafka 2016-12-22

---