Я пытаюсь вставить данные с помощью kafka автоматически в solr и banana, но это невозможно для меня...

Я могу прочитать поток из темы Кафки и записать (преобразованные) данные обратно в другую тему...

Я установил kafka и zookeeper в системе Windows.я запустил серверы kafka и zookeeper, создал тему...

Я попытался реализовать приложение Spark Streaming, которое считывает потоковые данные из Kafka

Допустим, у меня есть два следующих сообщения по теме A с одним и тем же ключом message1: (k, A1)...

Ниже приведена ссылка, относящаяся к потоковой передаче смещения темы kafka в pyspark. from pyspark

Я пытаюсь зарегистрироваться ниже класса для сериализации Kryo в коде искры, но я получаю сообщение...

H все, У меня есть требование, в котором мне нужно повторно принять некоторые из моих старых данных

Мы переносим наше приложение из Apache Kafka на платформу Confluent. Версия Apache Kafka: 1.1.0...

Привет всем, у меня есть вопрос о TimestampExtractor и Kafka Streams .... В нашем приложении есть...

Я пытаюсь запустить приложение Flask, которое использует Confluent Kafka для отправки сообщений на...

Я новичок в Scala / Spark Streaming и в StackOverflow, поэтому прошу прощения за мое форматирование

Я играю с TopologyTestDriver от Kafka Streams, чтобы протестировать наши конвейеры данных. Он...

Согласно документации (https://docs.confluent.io/current/streams/developer-guide/manage-topics

У меня есть 4 хоста, каждый со своим Заказчиком.Я понимаю, что для настройки нескольких Orderers мы...

Мой вопрос касается контрольной точки Kafka с репликатом, например, в асинхронном режиме...

Можно ли добавить значение в хранилище в Kafka Streaming, что я хотел бы сделать, если в теме...

Я попробовал следующее - ./confluent start, что дает - Этот CLI предназначен только для разработки,...

Мой вариант использования: получать сообщения с прошлыми (до 4 лет), текущими и будущими...

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

Примечания после обзора Я использую докернизированную версию Kafka и задание Kafka Streams.Это...

Я попытался реализовать wordCount от Kafka и получил ошибку «несоответствие типов» при...

Обязательны ли аргументы spring.cloud.stream.kafka.binder.zk?Что произойдет, если значение...

Я передаю длинную строку JSON String в тему kafka, например: { "glossary": {...

Давайте предположим, что значение является строкой ИЛИ объектом класса. context.forward(key, value,...