Я уже некоторое время пытаюсь заставить Spring Cloud Stream работать с Kafka Streams, в моем проекте для тестирования с Kafka DSL используется встроенная кафка, и я использовал этот репозиторий в качестве основы для моей тестовой реализации (он сам...

Я пытаюсь найти лучший способ выполнить действие с n -м событием в Kafka Streams. Мой случай: у меня есть входной поток с некоторыми событиями . Мне нужно отфильтровать их по eventType == login и для каждого n -го входа (скажем, пятого) для...

Я использую Processor API для обработки данных на низком уровне в хранилище состояний. Дело в том, что мне тоже нужно писать в тему после сохранения в магазин. Как это можно сделать в приложениях Spring Cloud Streams Kafka? @Bean fun...

Я работаю над Kafka Streams, используя Spring Cloud Stream. В приложении для обработки сообщений может быть вероятность, что оно выдаст ошибку. Таким образом, сообщение не должно повторяться и повторяться снова. Мой метод применения - @Bean...

Я пытаюсь выполнить flatTransform в приложении Spring Cloud Kafka Streams. Но я не уверен, где именно разместить аннотацию KafkaStreamsStateStore . На данный момент я получаю сообщение об ошибке: Invalid topology: StateStore activeInstruments is...

Я пытался запустить пример Spring загрузки Kafka Stream из https://cloud.spring.io/spring-cloud-stream-binder-kafka/spring-cloud-stream-binder-kafka.html#_usage_2 сайт. Умею его успешно построить. Но при запуске возникает ошибка, как показано...

Я знаю, что с помощью Kafka Connect вы можете создать коннектор, переводящий все сообщения kafka в тему PUBSUB. Я хотел бы знать, могу ли я использовать связыватели Spring Cloud Stream в сочетании с Spring Cloud Function и развернуть все это в...

Вкратце: включение функции маршрутизации событий, похоже, автоматически создает тему routingFunction-out-0, и мы не знаем почему, и мы не хотим этого. Как? Некоторый контекст: мы используем связыватель kafka для подключения к Azure Eventhubs и...

Я использую связыватель kafka spring-cloud-stream с реестром схем (не потоки kakfa). Я пытаюсь сделать, когда недесериализуемое сообщение попало во входную тему, отправить недесериализуемое сообщение в dlq. Итак, я попробовал, как показано...

У нас есть чтение топологии из входной темы (с binder: x - адрес брокера: x), и записи обрабатываются и записываются в выходную тему (с binder: y - адрес брокера: y) с использованием потоков Spring Cloud Stream Kafka. Записи в тему вывода не...