Я занимаюсь разработкой приложения (на основе микросервисов), опираясь на Kafka и Kafka Streams. Я...

Документы неясны.Когда бы я хотел установить сохранение дубликатов в false / true.Для чего это...

Я хочу настроить производительность Kafka Streams, и для этого мне нужно поиграть со значениями...

В приложении № 1 я создаю KTable - KTable<Windowed<String>, GenericRecord> table =...

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

У меня есть загрузочное приложение Spring, которое использует Processor API для создания топологии,...

Я использую Sprin облачную стрема Kstream.Я тестирую одну тему и одну @StreamListner.Это нормально....

Я использую тестовую установку, включая платформу (докер), и обрабатываю записи со следующей...

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

У меня есть тема с несколькими разделами в моем потоковом процессоре, я просто хотел передать это...

Мы делаем poc для потоковой передачи kafka vs jet, я заметил, что kafka нужен сериализатор и...

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

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

KTable<Key1, GenericRecord> primaryTable = createKTable(key1, kstream, statestore-name);...

Как вы управляете состоянием в сервисной сетке в Istio? Я вижу, что потоки Кафки - это один из...

ПРЕДИСЛОВИЕ: В нашей организации мы пытаемся использовать Kafka для решения проблемы, которая...

Я пишу приложение Spring Boot с помощью Spring Kafka. Поскольку мое приложение ориентировано на...

Я планирую приложение Spring + Kafka Streams, которое обрабатывает входящие сообщения и сохраняет...

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

Я понимаю разницу между 2, но все же, похоже, что я использую KTable в качестве "по умолчанию", не...

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

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

Я хочу использовать API-интерфейс Spring Cloud Stream для агрегации событий из темы. Поэтому я...

Я пытаюсь настроить тестирование, как предлагается здесь, на GitHub ссылка Map<String,...

Я пытаюсь создать bean-компонент kstreams и автоматически связать его с моим сервисом. Но даже если...