Я зарегистрировал схему в разделе «Физика» в реестре schmema. curl -X POST \...

Мы разрабатываем приложение SpringBoot, в котором сообщения генерируются в очередь Kafka и...

Итак, я читал это: https://thehoard.blog/how-kafkas-storage-internals-work-3a29b02e026 По поводу...

Мы пытаемся оценить производительность в нашей топологии Storm. Мы принимаем сообщения около 1000 в...

Я успешно настроил SASL PLAIN и PLAINTEXT для брокеров Kafka, в том смысле, что клиенты не могут...

Наша топология шторма обрабатывает сообщения из Темы 1 и отправляет их в Тему 2, и сообщение имеет...

Запрос на выборку такой же. maxWait: 100ms minBytes: 1 fetchSize: 1048576 Когда я использую с...

Может ли этот отстающий потребитель предотвратить удаление файла сегмента? В противном случае файл...

В текущей инфраструктуре мы настроили ванильный apache Kafka, и мы начали регистрировать некоторые...

Я получаю следующую ошибку: "ОШИБКА WorkerSourceTask (id = test-mysql-dbc-source-0) Не удалось...

У меня 3 потребителя подписались на тему Кафки. Производитель публикует 1 сообщение в теме. Как я...

Я использую нативную apache kafka, а не конфлюентную версию kafka. Я использую плагин kafka jdbc...

Я использую Kafka и zookeeper в Kubernetes, и когда я включил аутентификацию SASL, Kafka...

Я использую CCC с потоком Кафки, который заполняется соединителем Postgres из Debezium. Я использую...

Я пытаюсь реализовать очень простой Apache Flink CEP для Kafka InputStream. Производитель Kafka...

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

Я делаю весеннее приложение, используя Storm 1.1.2, JDK 8 (Storm не понравился скомпилированный код...

Я использую эту схему руля: https://github.com/helm/charts/tree/master/incubator/kafka и эти...

Я работаю над сохранением статуса потребителя в ребалансе Кафки.Я обнаружил, что псевдокод в...

У меня есть слушатель Кафки, помеченный @Controller: @KafkaListener(topics = "${binlookup

У меня есть задание Flink, которое записывает данные в Kafka. В теме Kafka максимальный размер...

У меня есть производитель кафки, определенный как public KafkaMessageProducer(String kafkaHost,...

Я пытаюсь найти хорошего сервера очередей / брокера сообщений, который может дать мне возможность...

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

Я вижу ниже WARN в моем производителе Kafka. WARN [kafka-producer-network-thread | producer-4] o.a