Допустим, у меня есть два следующих сообщения по теме A с одним и тем же ключом message1: (k, A1)...
Так что я совсем недавно начал читать о Kafka, и меня немного смущает разница между Kafka Connect и...
H все, У меня есть требование, в котором мне нужно повторно принять некоторые из моих старых данных
Привет всем, у меня есть вопрос о TimestampExtractor и Kafka Streams .... В нашем приложении есть...
Я играю с TopologyTestDriver от Kafka Streams, чтобы протестировать наши конвейеры данных. Он...
Согласно документации (https://docs.confluent.io/current/streams/developer-guide/manage-topics
Можно ли добавить значение в хранилище в Kafka Streaming, что я хотел бы сделать, если в теме...
Мой вариант использования: получать сообщения с прошлыми (до 4 лет), текущими и будущими...
Примечания после обзора Я использую докернизированную версию Kafka и задание Kafka Streams.Это...
Давайте предположим, что значение является строкой ИЛИ объектом класса. context.forward(key, value,...
Когда я пишу приложение, используя Processor API, и если я использую addSink для передачи журналов...
В документации говорится: state.dir Каталог состояний.Kafka Streams сохраняет локальные состояния в...
У меня есть два потока приложений kafka. Я могу видеть там группы потребителей, используя:...
Я работаю в среде разработки с 3 (докеризованными) брокерами kafka в моей системе.У брокеров для...
Мне было поручено разрушить среду разработки и заново настроить ее с нуля, чтобы проверить наши...
Когда метод process вызывается при переопределении класса процессора низкого уровня (например,...
Скажем, у вас есть тема с нулевым ключом, значение которой равно {id:1, name:Chris, age:99}...
Ниже приведен пример кода, в котором мы пытаемся удалить дубликаты на основе некоторого значения...
В приложении моей компании, чтобы применить несколько преобразований к 2 группам сообщений,...
Я использую Kafka Stream для своей темы A, и я использую в MemoryKeyValueStore. builder
Это вопрос новичка к кафке-стримингу. Как бы вы собрали пары сообщений, используя библиотеку java...
У меня есть 2 модульных теста , когда я их запускаю, у меня появляется ошибка ниже 1) test @Test...
Какая разница между этими сущностями? Как мне кажется, KTable - простая тема кафки с compaction...
У меня в приложении обрабатывается поток Kafka: myStream .mapValues(customTransformer::transform)
У нас есть проблема с удалением каталога состояний в потоковом приложении Kafka.Мы работаем с...