у кого есть проблемы с выходным форматом коннектора File Sink? Интересно, почему я получаю такой...

Я использую spring-kafka в приложении spring-boot для отправки темы данных.Мне нужно получить...

У меня запущен сервис Kafka, я использую авторизатор по умолчанию для ACL kafka, созданные ACL...

Я вдруг получил исключения типа в производстве Kafka ERROR[pool-XX-thread-YY] org.apache.kafka

B1, B2, B3 - брокеры Уменьшите B2, B3 - теперь B1 становится лидером по темам Уменьшить B1...

У меня есть пружинный ботинок с интегрированным потребителем кафки. что он делает, Использование...

Я пытаюсь закодировать объект класса для отправки с использованием производителя kafka. Класс имеет...

Я настроил следующую среду: https://medium

Как мне получить размер одной записи в Kafka? Существует некоторая информация о том, зачем мне это...

У меня есть подпрограммы Spring-boot Kafka pub sub, как показано на рисунке.Я хочу сделать...

Я написал простой клиент для чтения из темы Кафки, которая работала хорошо, пока я не понял, что...

Мы используем mirror maker для синхронизации по темам помещения и aws kafka.Как можно реплицировать...

когда я запускаю эту команду /root/heraldhealth/softwares/confluent-5.2.1/bin/confluent-hub install...

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

У меня есть приложение springBoot, которое имеет несколько бинов, которые запускаются и работают...

Я пытаюсь использовать потребителя и производителя библиотекой npm kafka-node. Чтобы использовать...

Я использую авторизатор ACL по умолчанию Kafka, но недавно я наткнулся на тему настраиваемого...

Предположим, у меня есть тема Kafka с именем account с несколькими типами сообщений (каждый со...

У меня кластер 3 узла Kafka на AWS .Чтобы убедиться, что кластер Kafka работает правильно, я...

У меня есть несколько серверов, с которых будут создаваться сообщения, и мне нужен брокер и...

Я пытаюсь создать dockerfile, в котором есть wurstmeister / zookeeper и wurstmeister / kafka. Если...

В проекте моей новой работы я обнаружил, что вместо непосредственного выполнения API-вызовов post /...

У меня есть ряд тем по кафке со значительным отставанием для конкретной группы потребителей.Кажется...

Запрос KSQL не возвращает ответ через API REST. ДАЖЕ Я использую ограничение CLAUSE.Моя тема...

Я пытаюсь подключить Сертифицированный Bitnami Kafka AMI со средой Elastic Beanstalk nodejs,...