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

Под /tmp/streams-my-application-id Я нашел файлы, которые использует RocksDB. Я хотел проверить...

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

При использовании процессора с сохранением состояния, состояния также могут быть сохранены в kafka....

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

Мне нужно использовать функцию из библиотеки kafka stream 2.2, однако моя базовая версия брокера...

Я создал Serde, потребляющий от kafka, как следующее import org.apache.kafka.connect.json

Я пытаюсь вывести конфигурацию приложения spring-kafka, которое я сейчас написал в коде Java.Должен...

Я заметил, что мое приложение Kafka Streams перейдет в состояние ERROR после невозможности...

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

Я использую материализованную KTable для использования в левом соединении с моим KStream (в то...

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

Я пытаюсь выполнить агрегацию в потоке с ключом типа String и значением пользовательского типа -...

В методе процесса @StreamListener я сопоставляю школу KStream с персоной KStream и с помощью метода...

У меня есть следующий код //Kafka Config setup Properties props = ...; //setup List<String>...

У меня есть два потока: [тема A] -> обработка A -> [тема B] -> обработка B -> [тема C] Со входом в...

Я работаю с API kafka streams и сталкиваюсь с проблемами, когда я подписываюсь на несколько тем, а...

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

Если я объявлю две топологии, в которых узел-приемник Application1 является узлом-источником...

Я создаю KStream с одним потоком, и я получаю эту ошибку Could not create topic:...

Я ищу подходящий учебник / руководство для java kafka-stream со схемой-реестром. У меня есть Google...

Мой текущий код использует InMemoryKeyValueStore, что позволяет избежать сохранения на диске.Я хочу...

мы сейчас находимся в процессе синхронизации данных из базы данных Oracle в новый экземпляр...

Я нашел два вопроса, спрашивающих, почему запись результата не генерируется, если в раздел не...

Я пытаюсь выполнить внутреннее соединение между KStream-KStream.Я заметил, что объединение не...