У меня есть приложение, которое разветвляется на одну из 20 тем на основе некоторых правил. Это...

У меня есть приложение kafka, настроенное на использование реестра схемы.V1 приложения была...

Получение исключения при чтении из темы kafka: вызвано: org.apache.kafka.common.errors

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

У меня есть приложение (spring-boot-shipping-service) с KStream, которое получает сообщения...

У нас есть кластер kafka, работающий со схемами Avro, которые хранятся в реестре схем Confluent....

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

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

у нас есть KafkaAvroSerde, настроенный с несколькими URL-адресами для авторегистрации. В какой-то...

KStream<String, String> left = builder.stream("source1"); left

У меня есть два потока: Stream1: [KSTREAM-MAP-0000000004]: 1, {"id": 1, "name":...

У меня есть следующая конфигурация для моего приложения Kafka Stream Properties config = new...