Я пытаюсь использовать хранилище состояний для дедупликации сообщений, полученных топологией...
Я создаю данные из одной темы А в другую Б, используя потоки. Но это очень медленно.В теме A есть...
У меня есть объект потока kafka, подобный этому: [KSTREAM-SOURCE-0000000000]: null,...
Я хочу написать потребителя kafka, используя формат protobuf, так как сообщение в формате proto, я...
У меня есть следующая конфигурация для моего приложения Kafka Stream Properties config = new...
Этот вопрос задавался и решался пару раз, но из-за моих очень ограниченных знаний я не могу найти...
Я ищу лучший способ читать сообщения (много сообщений, около 100B каждый день) из Кафки, после...
Я пытаюсь запустить приложение Kafka Streams в kubernetes. Когда я запускаю модуль, я получаю...
У меня есть тема об одном брокере с постоянно поступающими данными о кликах пользователей. Я хочу,...
Я запускаю две банки. каждый запускает экземпляр воспламенения (порты 47500 и 47501). jar извлекает...
Я знаю, что Кафка использует RocksDb внутри. Если я использую KTable для хранения словаря данных,...
Я проверял потоки Кафки. Я тестировал приведенный ниже код для потоков Kafka Тема продюсера: (это...
У меня есть несколько проблем с созданием KTable с временным окном в Kafka. Я хочу создать таблицу,...
Использование Spark Streaming для чтения и обработки сообщений от Kafka и записи в HDFS - Hive. Так...
Я хотел бы использовать Kafka для выполнения ограниченной пакетной обработки , когда программа...
У меня есть два потока Kafka с ключами в String и значениями в формате Avro, которые я создал с...
Я новичок в программировании потокового воспроизведения. как я могу отобразить результат и...
Эта проблема теперь решена в Центре сообщений У меня возникли проблемы с созданием KTable в Кафке....
У меня есть некоторый опыт IMDG. Я довольно новичок в KAFKA. Я пытаюсь понять вариант использования...
Я новичок в Stackoverflow, так что простите, если вопрос задан плохо. Любая помощь / вдохновение...
Я хочу перезапустить мое приложение kafka Stream после перехвата исключения в обработчике...
Мне нужна помощь в создании тестового примера Junit для моего потребителя Java-кафки. Исходный код...
Я пытаюсь подключить мой Kafka к HDFS, но при запуске конфигурации я получаю следующую ошибку: java
Я хочу частично собирать элементы в списки в потоках Кафки через определенный промежуток времени...
У меня есть приложение Kafka Streams, которое получает записи во входную тему, выполняет некоторую...