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

В настоящее время я использую SCS с почти стандартной конфигурацией для отправки и получения...

Одно из потоковых приложений Kafka генерирует много ошибок Unknown Producer Id в брокерах Kafka, а...

В приведенном здесь примере: https://github.com/confluentinc/kafka-streams-examples/blob/5.1

Я пишу приложение KafkaStreams (v2.1.0), которое читает сообщения из обычной темы Kafka, объединяет...

Доброе утро, ребята, Я пытаюсь запустить приложение Kafka Stream, но каждый раз, когда я пытаюсь,...

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

каждый день мы будем получать сообщения ниже в Student-Topic-In Message 1: {"StudentID":...

Я использую Confluent 5.0.0 версии * У меня есть массив JSON, как показано ниже: { "name"...

У меня есть приложение Kafka Streams, для которого при каждом перезапуске смещения для темы,...

У нас есть потоковое приложение, которое использует семантику "точно один раз", когда один...

Мы запускаем весеннее облачное приложение, использующее spring-cloud-kafka-streams. Приложение...

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

У меня есть случай, когда мне нужно прочитать данные из темы, а затем пакетные данные (100 записей)...

Можно ли получить оконный конечный результат в потоках Кафки, подавив промежуточные результаты. Я...

У меня есть тема, которая читается как GlobalKTable и материализована в магазине. Проблема в том,...

Я пытаюсь запустить очень простой поток, используя ProcessorAPI в Scala. class KafkaProcessor...

У меня запущено приложение kafka stream, которое будет принимать сообщения из темы всякий раз,...

Мы планируем использовать оператор подавления над сеансным оконным KTable. Нас интересует...

У меня есть простой сценарий для задания ETL: взять данные из темы Кафки и поместить их в таблицу...

Я пишу приложение Kafka Streams с использованием DSL API, которое будет читать кортежи из темы...

Должны ли мы когда-либо сами вызывать processorContext.commit() в Processor реализации? Я имею в...

Попытка пакетной записи с помощью API процессора потоков Кафки. Дозирование основано на размерах и...

Я пытаюсь создать DSL-код Materialized.as здесь: https://kafka.apache

Моя установка состоит из 3 брокеров kafka (2.11-1.1.1), одного ZK и сервиса java, который...