Я пытаюсь реализовать механизм повтора для моей темы Kafka.поэтому я установил количество повторных...

Я новичок в Kafka и просматриваю доступную официальную документацию. В моей локальной системе я...

Я использую кластер MSK с 3 брокерами в AWS. ClusterMetrics показывает, что GlobalTopicCount равно...

Мы поддерживаем количество разделов по умолчанию для темы Kafka, равное 10, независимо от данных

Я создал демонстрационное приложение, используя KafkaStream API.Попытка запустить приложение с...

С Alpine, Alpine полностью поддерживает последние версии librdkafka, я могу просто сделать apk add...

Могут ли транзакции JDBC и транзакции kafka работать вместе как транзакция XA?Поддерживает ли API...

Существует система, в которой участвуют три бизнес-участника: исполнителей клиентов (мобильное...

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

У меня есть следующий код Python: from data_pipeline.scraper_processor import ScraperProcessor def...

Моя настройка следующая: 3 узла Zookeeper защищены следующим образом: SASL включен (quorum.auth

Используя образцы из разных источников, я написал этот метод (соответствующий раздел показан ниже),...

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

Как удалить тему Kafka, имя которой содержит пробел? Например, имя темы Kafka - «тестовая тема», я...

Я новенький в весенней кафке.У меня есть микросервис, который отправляет сообщение с ключом kafka,...

Я создал bean-компонент: @Bean public Map<String, Object> consumerConfigs() { Map<String,...

При настройке docker compose только с 1 узлом kafka и zookeeper Я могу писать в тему, но не могу...

Когда я использую: bin/kafka-console-consumer.sh --consumer.config kafka.properties...

Я хочу иметь 3 реплики kafka на 3 разных машинах. На первой машине я запускаю zookeeper со...

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

Один из потребителей кафки, который у нас есть, должен идентифицировать некоторые шаблоны в...

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

У меня есть два узла соединителя Kafka, скажем Node-A и Node-B. Я запускаю одного распределенного...

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

Я не могу заставить мой Java-клиент Kafka работать.Симптомы: «Обнаружен координатор» отображается в...