Я использую клиентскую библиотеку .NET из Confluent. Мне нужно подключиться к теме и прочитать...
Jhipster 5.7 создает файл kafka.yml, ссылающийся на kafka 1.0.0.Кафка 2.x хорошо поддерживается (и...
Я создаю KTable из темы в формате значения JSON, производители темы также включают ключ для каждого...
Я использую это Дебезиум-примеры source.json { "name": "inventory-connector",...
Я хочу загрузить данные, которые хранятся в HDFS, используя kafka.Я сделал программу, которая...
Я пытаюсь вставить данные в базу данных postgres из темы в kafka.Я использую следующую команду для...
Я создаю приложение, используя сервер конфигурации Spring Cloud в качестве централизованного...
У нас были процессоры, которые передают смещение через производителя для достижения точной...
Проблема: при попытке отправить сообщение от производителя с SSL сообщение получено на стороне...
Я довольно новичок в Kafka и пытаюсь настроить и запустить простую систему соединения kafka с...
Каков наилучший способ реализации производителя Kafka в RoR с использованием ruby-kafka (0.7.4) gem...
Я пытаюсь настроить брокера kafka и у меня возникли некоторые вопросы о том, как брокер...
Я следую простой документации по использованию потоков Kafka с пружинной загрузкой ( Spring guide )...
чтобы запустить приложение с весенней загрузкой без необходимого запущенного сервера kafka, я...
Я пытаюсь запустить докерскую кафку и масштабировать ее на моем локальном хосте.Вот мой...
Я пытаюсь настроить тест для перемещения данных из MySQL в Elasticsearch. У меня есть докерская...
Я устанавливаю управляемую очередь kafka на AWS MSK.Кажется, я не могу заставить работать систему...
Почему существуют два разных свойства для метрической отчетности?Что отличает их? Если они...
Каким образом брокер kafka аутентифицирует (используя kerberos) друг друга для взаимодействия между...
Я пытаюсь написать CronJob для выполнения сценария оболочки в ConfigMap для Kafka. Я намерен...
у нас есть один потребитель кафки, который постоянно опрашивает тему кафки и обрабатывает сообщения
Использование: confluent-5.1.0 SINK Конфигурация: curl -X POST \ http://localhost:8083/connectors \...
Мы строим систему источников событий в моей компании, опираясь на Kafka. Чтобы быть совместимыми с...
Я использую kafka версии 2.12-2.1.0 в Linux и успешно сохраняю сообщения.Теперь метаданные...