У меня есть простое приложение Spring, основанное на Kafka Streams, которое принимает сообщение из...

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

У меня есть одна тема Kafka с несколькими пользовательскими информационными событиями для...

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

Я реализую прикладную программу apache kafka stream на Java на машине GCP.Я использую kafka версии...

Я добавил несколько процессоров в свою топологию. Работает только 1 процессор. Я могу получать...

Я пытаюсь понять kafka в некоторых деталях относительно потоков kafka (клиент потока kafka для...

Я пытаюсь смоделировать Gwen (Chen) проект Кафки-clickstream-enrich kafka-stream Шапиры на GitHub...

У меня есть две темы, которые связаны StreamProcessor: Тема A -> Процессор A -> Тема B Я отправляю...

Я заметил исключение stream-thread [x-CleanupThread] Не удалось удалить каталог состояний с нашим...

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

Я использую Kafka DSL.Как бы я продолжил подавлять вывод агрегации (поведение, подобное this ) с...

Я использую Streams DSL и выполняю агрегацию с сохранением состояния (чтение данных из темы,...

В моем приложении почти все значения входящих записей обнуляются (засыпаны гробницей) в течение...

У нас есть входящая тема кафки с несколькими сообщениями на основе схемы Avro, сериализованными в...

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

Я искал пример, использующий Kafka Streams, о том, как сделать такого рода вещи, то есть объединить...

У меня есть настоящий env с кластером машин 3 кафка, который получает много данных.Для каждой темы...

Из https://micronaut -projects.github.io / micronaut-kafka / latest / guide / # kafkaStream , я...

Мне нужна помощь в понимании поведения потока Kafka, когда max.task.idle.ms используется в Kafka 2

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

Допустим, у меня есть A-Event KStream, агрегированный в A-Snapshot KTable, и B-Event KStream,...

Мое потоковое приложение kafka выдает следующее исключение и умирает после того, как кластеру kafka...

Я использую последний Greenwich.SR1, который включает Spring-Cloud-Stream (версия: Fishtown.SR2) и...

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