В методе процесса @StreamListener я сопоставляю школу KStream с персоной KStream и с помощью метода...

У меня есть следующий код //Kafka Config setup Properties props = ...; //setup List<String>...

Я ищу подходящий учебник / руководство для java kafka-stream со схемой-реестром. У меня есть Google...

Мой текущий код использует InMemoryKeyValueStore, что позволяет избежать сохранения на диске.Я хочу...

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

У меня есть очень простой Beam Pipeline, который читает записи из темы Кафки и записывает их в тему...

Я пытаюсь выполнить внутреннее соединение между KStream-KStream.Я заметил, что объединение не...

У нас есть запрос, касающийся потребления памяти при масштабировании kafka. Было бы очень полезно,...

Я сталкиваюсь с проблемой присоединения KStream к GlobalKTable и буду признателен за вашу помощь....

Я использую Confluent platform 5.2.1 и исходный соединитель jdbc для чтения данных из таблицы MySql

У меня есть следующее //Config setup Properties props = ...; //setup List<String> topicList =...

Я использую Maven 3 для запуска приложения, но получаю следующую ошибку: [ERROR] [ERROR] Some...

Я пытаюсь обработать запрос в Presto с использованием JDBC и передать набор результатов обратно в...

Я пытаюсь сделать следующее: For Clients to Broker communication - use OAUTHBEARER authentication...

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

Я пытаюсь CDC, используя Debezium и Kafka. Я зарегистрировал соединитель с 3 таблицами в свойстве...

Мы разрабатываем приложение Kafka Streams, используя низкоуровневый процессорный API. Согласно...

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

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

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

Я пытаюсь смоделировать потоковый трафик с помощью Kafka to Storm.Я использовал KafkaSpout для...

Я пытаюсь сделать следующее: Setup SASL/PLAIN for inter-broker communication Setup SASL/PLAIN for...

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

Можно ли использовать KeyValueStore в качестве KTable?KeyValueStore будет заполнен операцией...

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