Я занимаюсь разработкой простого приложения Kafka Stream, которое извлекает сообщения из темы и...
Мы используем Kafka 0.10.2.0, потоки kafka 1.1.0.У нас есть Kafka Cluster из 16 машин, а тема,...
Создание KStream из темы и возможность получать данные из нее.Попытка объединить 2 потока,...
У меня есть потоковое приложение с 2 тематическими источниками.одна тема читается как KStream, а...
Изучение потоков Кафки, попытки объединить два потока (значение Json) в 5-минутном окне.Насколько я...
Можно ли пересылать входящие сообщения с пользовательскими заголовками из темы A в B в потоковом...
Моя проблема заключается в следующем: У меня есть 2 темы kafka: customer-purchase: содержит...
У меня есть два потока: Stream1: [KSTREAM-MAP-0000000004]: 1, {"id": 1, "name":...
Я изучаю Kafka Streams и пытаюсь достичь следующего: Создано 2 темы Kafka (скажем topic1, topic2) с...
Я пытаюсь создать Transformer и сталкиваюсь с проблемами при инициализации его StateStore.Я...
Я пытаюсь понять разницу между joinWindows.of и joinWindows.until при выполнении левого соединения
Мы рассматриваем Kafka Streams как способ решения сравнений в полете.В частности, у нас есть данные...
Я новичок в кафке.Есть ли какой-либо API для отображения результатов, такой же, как у файла...
У меня был сценарий для чтения данных JSON из моей темы Kafka, и, используя версию Kafka 0.11, мне...
Чтобы создать хранилище состояний потоков Кафки в Java, я могу сделать это: final...
пытается соединить два Kstream, но я получаю сообщение об ошибке несоответствия типов, ниже...
Мне нравится Кафка, но я ненавижу писать много сериализаторов / десериализаторов, поэтому я...
Я использую следующие log4j.properties log4j.rootLogger=DEBUG, stdout log4j.appender.stdout=org
Team, Какой стратегии следует придерживаться при развертывании приложений Kafka-streams? У нас есть...
Нам нужно выполнить соединение Kstream - Kstream с очень большим окном, где отметка слева будет...
Я пишу приложение в Kafka v1.0 Streams и сталкиваюсь со странной проблемой времени выполнения,...
Исходя из фона Spark Streaming - получить представление о потоках Kafka. У меня есть простое...
Этот вопрос касается внедрения GDPR в приложении Kafka Streams, с полной темой хранения с...
У меня есть поток Kafka с входящими сообщениями, который выглядит как sensor_code: x, time:...
STREAM-1: [KSTREAM-SOURCE-0000000000]: null, {"id": 1, "name": "john"...