Я использовал kafka для потоковой передачи своих сообщений, закодированных с помощью msgpack.После...

Мы используем Spring Cloud Stream Kafka Binder (с интеграцией Project Reactor, т.е. Flux потоки ) и...

Каково поведение Offset Management кластера Kafka Connect в распределенном режиме, в котором...

Я настраиваю мониторинг подключения Kafka в нашей экосистеме Kafka.Я включил экспортер JMX для...

Я хотел бы создать скрипт на python для отправки файлов с виртуальной машины и отправки их брокеру...

Можем ли мы динамически добавить больше брокеров в Kafka Cluster и добиться отработки отказа...

У меня 2 брокера кластера kafka 0.10.1, ранее запущенных на моих серверах разработки с zookeeper 3

у нас есть кластер Кафка как все знают, чтобы удалить темы из kafka и zookeeper необходимо...

Я новичок в kafka, я пытаюсь использовать данные из kafka, используя python, который занимает 10...

SMT не работает с приведенной ниже конфигурацией, любая идея "transforms":...

Я определил кластер Kafka из двух узлов с коэффициентом репликации 2. Когда я пытаюсь использовать...

Учебное пособие https://docs.microsoft

У меня есть требование, когда мы будем «разжигать» кучу финансовых потоков разных поставщиков в...

При какой конфигурации можно отправлять только один ProducerRecord с KafkaProducer, чтобы не...

Я пытаюсь использовать Kafka в среде Windows.Однако, поскольку я использую машину с Windows 10,...

Я ищу способ получения каждой записи об ошибках в обработчике массовых ошибок kafka вместо...

Я пытаюсь запустить экземпляр Zookeper и получаю сообщение об ошибке, в котором говорится, что файл...

У нас есть тема с 3 разделами, в которой публикуется 1,5 ГБ данных в минуту, но все записи...

Дебезиум перестал работать сразу после того, как я добавил TRIGGERS в свои таблицы MySQL. Это то,...

Когда регистрация пользователя завершена в моем приложении для Android, мне нужно создать нового...

У меня есть запланированный fw планировщик, в котором кварц выполняет триггер, который запускает...

Я не могу запустить zookpeer для дальнейшего запуска Кафки.Моя структура папок: Root bin...

Я пишу приложение Spring Boot, которое потребляет большое количество каналов kafka.Миллионы данных...

Я создаю свои соединители источника / приемника Kafka Connect с помощью процесса редактирования...

У меня есть такой сценарий, который преследует меня: тема Кафки с сообщениями, которые я должен...