Я столкнулся с аналогичной проблемой, упомянутой в https://github

Я работаю над сервисом, который использует kafka streams api.Мне интересно, есть ли способ...

Я пытаюсь создать приложение KStream в Eclipse, используя Java. сейчас я имею в виду программу...

Мы используем весенний облачный поток с Kafka 2.0.1 и используем InteractiveQueryService для...

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

Я смотрю учебник по Pipe . Мне нужно нечто подобное, но только местное. Другими словами, код в...

Я только что определил топологию KStreams впервые и хотел бы быстро проверить работоспособность,...

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

Hello Kafka community. Я работаю над службой, которая использует API потоков Kafka. Есть ли способ...

Используя spring-boot-2.1.3, spring-kafka-2.2.4, я хочу иметь две конфигурации потоков (например,...

Я новичок в Kafka Streams и использую его для точного копирования темы в другую с другим именем.В...

Я использую openjdk: 8-alpine для развертывания приложения Kafka Streams.Я использую Windowing, и...

У меня есть следующая конфигурация потока kafka. StreamBuilder builder = stream("TopicA",...

Я знаю, что можно настроить фактор репликации для этих внутренних тем для потоков kafka, наше...

Есть ли способ добавить глобальный магазин для использования Трансформером?В документах для...

Я не смог найти здесь и на веб-сайте и в блогах Spring, если Spring Cloud Stream может предоставить...

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

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

Я пробую Кафку Стримс.Написание простого приложения, в котором я считаю дубликаты сообщений....

У меня есть сценарий использования, когда мне нужно использовать заголовки в DSL, поэтому...

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

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

Существует топология: .mapValues((key, messages) -> remoteService.sendMessages(messages))

Я могу проверить поддержку заголовка в Processor API, используя контекст процессора.Мне нужно...

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