Я публикую Kafka с сообщениями JSON, например: "UserID":111...

Я работаю над Kafka Streams.Я сталкиваюсь со следующими проблемами: Подробная информация о том, что...

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

Какова стратегия / лучшие практики, когда мы сталкиваемся с ошибкой несовместимости схем (avro),...

У меня есть один узел кафка брокер и простое приложение потоков.Я создал 2 темы (topic1 и topic2)....

Я собираю значения в потоке следующим образом: private KTable<String, StringAggregator>...

Я хотел знать, какие операции с состоянием или операции без сохранения состояния мне нужно...

Недавно мы обновили Kafka до v1.1 и Confluent до v4.0. Но после обновления мы столкнулись с...

Я хочу использовать Java KStream в Kafka, чтобы отфильтровать все те значения, которые превышают...

У меня есть приложение 2 Kafka Streams.Одно приложение прослушивает, скажем, topic1 и производит на...

Я выполнил операции объединения двух kstream, которые состоят из данных формата avro, а затем мой...

Я работаю над проектом Stream Streaming, который берет данные из Kafka, применяет некоторые правила...

Я использую Kafka Stream API для тестирования некоторых функций.У меня есть поток наподобие:...

У меня простой вопрос, но я не могу понять, как добиться ниже, используя потоки Kafka в Java? Я...

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

Я получаю следующее сообщение об ошибке: Exception in thread "main" java.lang

Создание KStream из темы и возможность получать данные из нее.Попытка объединить 2 потока,...

Изучение потоков Кафки, попытки объединить два потока (значение Json) в 5-минутном окне.Насколько я...

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

Я изучаю Kafka Streams и пытаюсь достичь следующего: Создано 2 темы Kafka (скажем topic1, topic2) с...

У меня есть поток Kafka с входящими сообщениями, который выглядит как sensor_code: x, time:...

Я использую Scala для получения kafkaStream и хочу вставить эти данные непосредственно в Redis

Я готовлю приложение Kafka Stream с Java.Задача использует некоторые сообщения из темы, которая...

Я пытаюсь опросить тему kafka с помощью API KafkaConsumer. Но он переходит в состояние ожидания на...

Я использую Filebeat и Kafka для управления журналом. У меня есть запрос, который отправляет данные...