Я создаю потоковое приложение через Kafka Streams 2.10 и столкнулся с концептуальной проблемой. The...

То, что я хотел бы сделать, это: Использовать записи из темы считать значения для каждого окна...

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

Сгенерированный образец потока из утилиты ksql-datagen из следующей схемы - { "type":...

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

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

Я хочу присоединиться к двум потокам, и я установил окно объединения на 25 часов, так как записи,...

Я хочу использовать Kafka Processor API для обработки сообщений от Kafka.Я хотел бы вызывать...

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

Я хочу динамически генерировать некоторый код потока kafka, когда программа работает running, но я...

KafkaStream не смог произвести данные после долгого времени.(Превышение установленного времени...

Я пытаюсь создать простое приложение Kafka Streams, используя среду Spring Cloud Stream.Я могу...

Я пытаюсь оценить, будет ли поток kafka с хранилищем состояний rockdb и использоваться ли в...

Я использую Kafka Streams 1.1.0. Я создал следующую топологию: Topologies: Sub-topology: 0 Source:...

Я использую потоки Кафки в своем приложении, у меня есть вопрос о временном окне в статистической...

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

Я новичок в потоке Кафки, мой вариант использования - сравнить значение каждой отдельной входящей...

У меня есть несколько вопросов, касающихся потоков Kafka и того, как они работают, у меня есть опыт...

Я запускаю свое приложение с Java 1.6 и планирую немного интегрировать аспекты с Kafka. Я изучаю,...

Мы новички в докере, и у нас есть эта проблема на Mac OSX Это проект Kafka Java. https://github

У меня есть TimeWindowed KTable stream.table("topicA") .groupByKey()

Я немного играю с Kafka Streams и, исследуя WordCountProcessorDemo, я понял, что, должно быть, была...

Я пытаюсь создать приложение Kafka Streams, которое обрабатывает записи Avro, но я получаю...

Наша система kafka вышла из строя из-за отсутствия свободного места на диске.Потребителями являются...

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