У меня есть производитель Kafka, который производит сообщения с высокой скоростью (ключ сообщения...
Я хочу частично собирать элементы в списки в потоках Кафки через определенный промежуток времени...
У меня есть приложение Kafka Streams, которое получает записи во входную тему, выполняет некоторую...
Я использую Kafka Streams с Spring Boot.В моем случае использования, когда я получаю событие...
Я недавно обновился с kafka 0.10.1 до 1.1.0. Мое потоковое приложение создает потоки, подписываясь...
Я пытаюсь использовать KTable для использования событий из темы Кафки.Но это ничего не возвращает
Предположим, у нас есть тема Kafka, которая содержит 1000 сообщений.Мы создаем из него поток (в...
У меня есть KStream с данными из темы to1 , как это: T1-KEY -> {T1} T2-KEY -> {T2} и KTable ,...
Государственные магазины в Kafka Streams создаются внутри.Государственные хранилища разделены по...
Я создаю 30-минутное хранилище дедупликации для приложения Kafka Streams, свободно основываясь на...