Моя цель - развернуть коннекторы Kafka (приемник s3) с использованием контейнеров, поэтому важно...

Я попытался запустить confluent zookeeper systemctl Запустить confluent-zookeeper is return Не...

Я вижу некоторые недокументированные порты, используемые zookeeper в нашем развертывании kafka...

Я пытаюсь подключиться к Kafka 3.0 с SSL, но сталкиваюсь с проблемой при загрузке хранилища ключей...

Поэтому я использую колбу вместе с Кафкой для создания веб-приложения, которое позволяет...

Я использую kafka-node с cofluent kafka, который работает внутри докера. Вы знаете, что означает...

Кластер Kafka имеет узел контроллера и кластер Zookeeper, оба со своим собственным набором...

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

Я написал функцию потребителя Kafka, которая сначала извлекает сообщение из последнего прочитанного...

Совершенно новые серверы, новая установка с confluent-community-2.12 версии 5.3.1. Реестр схемы...

Мы ищем документацию, которая объясняет, как установить конфлюентную платформу через докер на 3...

Настройка: кластер из 3 узлов. У каждого узла есть зоопарк и кафка. Испытывая Кафку, мы создали...

У меня есть Kafka Connector, использующий что-то вроде следующего: SELECT CAST ( id as VARCHAR) as...

Предположим, мы используем Kinkka S3 Connector Connector в автономном режиме. Как написано на...

Я использую Spring Kafka с пружинной загрузкой 2.1.9 и confluentinc / cp-kafka: 5.3.0 (3 брокера...

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

У меня есть ряд сервисов, где клиенты Kafka много перебалансируют, когда брокеры находятся под...

Я использую Kafka_2.12 версия 2.3.0 . В целях удаления темы я использую приведенный ниже фрагмент...

У меня есть тема Кафки с одним разделом. Я пытаюсь отправить сообщения брокеру. Источник размером 1...

У меня есть приложение SpringBoot. 2.1.5.RELEASE, которая использует Spring для Apache Kafka...

Я хочу опрашивать только записи, которые произвели менее 30 секунд. Есть ли какой-либо способ в...

У меня есть настройка часового-редисса, имеющая 3 сторожа (Кворум 2) и 3 узла редис (1 мастер-2...

У меня есть вопрос о Кафке в Куберне, особенно автоматическом масштабировании ... Допустим, у меня...

Как мне использовать местоположение смещения, которое я указал до выполнения программы? Я пытался...

Я пытаюсь получить сообщения из темы в Kafka через простое загрузочное приложение Spring через...