Я пытаюсь настроить ssl на платформу док-сервера kafka и получаю сообщение об ошибке, когда...

Не уверен, правильно ли я понимаю этот вопрос: Используя KafkaUtils.createStream(), сама программа...

Я пытаюсь оценить, будет ли поток kafka с хранилищем состояний rockdb и использоваться ли в...

Я не могу определить ZipWith out как In другого ZipWith.Он получает только одно событие от одного...

ОБНОВЛЕНИЕ: Исправлена ​​ошибка.Была проблема с версиями.Нужно поменять spark-core и другие до...

Мне удалось распечатать вывод.Но я хочу записать их в Spark DataFrame и затем вставить их в таблицу

У меня есть дистрибутив Cloudera Hadoop, Spark и т. Д., Где версия Spark-Kafka - 0,8 (т.е....

До сих пор у нас есть приложение для пакетной обработки, в котором мы просили источник сообщить нам...

Я использую Kafka Streams 1.1.0. Я создал следующую топологию: Topologies: Sub-topology: 0 Source:...

Я новичок в Play Framework. Я пытался добавить библиотеки Spark и Kafka в build.sbt, но получаю эту...

Итак, я соединяю кафку с искрой и хочу найти это значение в моноблоке.Я не знаю, какой подход...

После интеграции Kafka в реактив, возникает какая-то проблема следующим образом. kafkaClient.js:728...

Я использую потоки Кафки в своем приложении, у меня есть вопрос о временном окне в статистической...

Я хотел бы отделить формат кодирования в теме Kafka от формата кодирования, используемого для...

Я сделал тест Кафки, и это сработало.но когда я запускаю программу в IDE, я получаю эту ошибку и не...

Я новичок в потоке Кафки, мой вариант использования - сравнить значение каждой отдельной входящей...

У меня есть несколько вопросов, касающихся потоков Kafka и того, как они работают, у меня есть опыт...

Я очень новичок в работе Kafka и Spark, я пытаюсь запустить работу, но получаю следующую ошибку и...

Интересно, могу ли я сменить операторов на работу, уже представленную Flink.Предположим, у меня...

Итак, в одной из наших тем о kafka есть около 100 ГБ данных.Мы запускаем потоковую передачу с...

Я работаю над небольшим проектом с использованием Spring Boot, Kafka и Spark.До сих пор мне...

Мы новички в докере, и у нас есть эта проблема на Mac OSX Это проект Kafka Java. https://github

Мне удалось успешно подключить соединитель GCS без включенного SASL или SSL.Когда я включаю SASL и...

Я немного играю с Kafka Streams и, исследуя WordCountProcessorDemo, я понял, что, должно быть, была...

Я недавно обновился до Spark 2.3.0.У меня была существующая работа на спарк, которая раньше...