Я пытаюсь запустить приложение Kafka Streams в kubernetes. Когда я запускаю модуль, я получаю...
У меня есть тема об одном брокере с постоянно поступающими данными о кликах пользователей. Я хочу,...
Topology streamTopology = new Topology(); streamTopology.addSource("Source1",...
Я прочитал несколько блоков для достижения масштабируемости в Kafka. мы должны использовать...
Я знаю, что Кафка использует RocksDb внутри. Если я использую KTable для хранения словаря данных,...
В моей компании мы широко используем Kafka, но мы используем реляционную базу данных для хранения...
Я проверял потоки Кафки. Я тестировал приведенный ниже код для потоков Kafka Тема продюсера: (это...
В Kafka StreamsBuilder подпись только для таблицы: table(java.lang.String topic) https://kafka
Я использую Кафку 1.1.0. Поток kafka последовательно выдает это исключение (хотя и с разными...
Я работаю на processor node в потоках кафки. Для простого кода я написал, как показано ниже, только...
У нас есть поток веб-событий. Событие разделено на (домен, uid). Все описанные здесь события...
Я бы хотел проверить свой процессор со встроенной кафкой. Это вообще возможно? Когда я запускаю...
У меня есть несколько проблем с созданием KTable с временным окном в Kafka. Я хочу создать таблицу,...
У меня есть два потока Kafka с ключами в String и значениями в формате Avro, которые я создал с...
Как заставить потоки кафки работать с log4j? Например, выполнение ниже не приводит к выводу в...
Я пишу приложение KafkaStreams, которое принимает строковые значения из темы, где я хотел бы...
Я пытаюсь создать хранилище сеансов в памяти с помощью Kafka Streams, но не могу найти такую...
[ { "device_nm": "x1", "type": "external",...
Эта проблема теперь решена в Центре сообщений У меня возникли проблемы с созданием KTable в Кафке....
У меня есть тема Кафки t1, которая содержит 100 сообщений. После операции flatMapValues ()...
Я новичок в Stackoverflow, так что простите, если вопрос задан плохо. Любая помощь / вдохновение...
Я хочу перезапустить мое приложение kafka Stream после перехвата исключения в обработчике...
Я пытаюсь рассчитать окно с примером количества слов. Он работает нормально, за исключением того,...
У меня есть потребительский класс Kafka, который прослушивает события и выполняет объединение между...
У меня есть приложение Kafka Streams, которое получает данные из темы-1 как KStream и темы-2 как...