KStream<String, dummy> demoZone = builder.stream(fromTopic, Consumed.with(Serializer

У меня агрегированное хранилище через DSL через оконную агрегацию через поток.Затем я получаю из...

У меня есть процессор, который берет строку json из темы с типом GenericRecord.Теперь я разделил...

У нас есть простое развертывание kafka 1.1.0 в автономном режиме на нашей машине с Linux.В файле...

Я использую Kafka для потоковой передачи файла JSON, отправляя каждую строку в виде сообщения.Один...

Я использую kafka connect cassandra source connector 1.0 version.У меня есть столбец десятичного...

У меня потоковое задание выполняется с использованием SBT. всякий раз, когда я делаю "sbt run", я...

При запуске весеннего загрузочного приложения я получаю отладочную информацию, которая отображает...

Я работаю над простым скриптом Python для потоковой передачи сообщений от Kafka с использованием...

Я создаю приложение Spark SQL, которое использует тему Kafka, преобразует некоторые данные, а затем...

У меня есть приложение SCS Sink.Я пытаюсь отправить сообщение MessageBuilder темам kafka с помощью...

Даже после многих попыток я не вижу ни сообщения ни на консоли, ни записанного в файл. Ниже моего...

Я настроил Confluent Cloud с KSQL Server со следующей конфигурацией, как предложено, bootstrap

У меня есть приложение kafka stream, работающее с 36 различными экземплярами (по одному для каждого...

Сохраняю смещение темы Кафка в таблице на Hbase.Я использую эту тему для запланированного задания...

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

Когда я использую «Stream Streaming» для чтения «kafka» (требующего проверки sasl) и затем сохраняю...

у нас есть приложение, которое нам нужно, чтобы сгруппировать миллионы событий в соответствии с...

Должен ли я использовать Kafka Consumer API или Kafka Streams API для этого варианта использования?...

Я хотел бы использовать сообщения.Если я получу исключение, я попытаюсь повторить экспоненциальный...

Я читаю документы Filebeat Json по центральной теме. Фильтрация на основе источника / пути к файлу...

Привет, я новичок в искре. У меня есть сценарий получения потока данных из тем кафки в оконном...

Я использую спарку с помощью кафки, у меня есть тема с 20 разделами.Когда выполняется потоковое...

Я использую Confluent KafkaAvroDerserializer для десериализации объектов Avro, отправленных через...

Я работаю с Apache Spark 2.4 и читаю данные json из kafka после применения многократного...