/
DOCS
Облачная платформа
Advanced
Поиск
В этом документе
Эта статья полезна?
Документация DMS for Kafka
Обзор сервиса
Что такое DMS for Kafka?
Что нового
Квоты и лимиты
Преимущества продукта
Сценарии применения
Kafka Instance Спецификации
Cluster Kafka Instances
Сравнение Kafka, RabbitMQ и RocketMQ
Сравнение DMS for Kafka и Open-Source Kafka
Примечания и ограничения
Сопутствующие сервисы
Базовые концепции
Разрешения
Начало работы
Начало работы с Kafka для производства и потребления сообщений
Процесс использования Kafka
Permissions Management
Создание IAM User и предоставление разрешений DMS for Kafka
Покупка Kafka Instance
Настройка тем
Создание Kafka Topic
Настройка разрешений тем Kafka
Управление топиками
Просмотр сведений о теме Kafka
Просмотр журналов тем Kafka
Изменение конфигураций Kafka Topic
Изменение количества разделов Kafka
Изменение Kafka Topic Replicas
Экспорт списка тем Kafka
Переназначение разделов Kafka
Настройка Automatic Topic Creation
Удаление темы Kafka
Подключение к Instance
Настройка сетевых соединений Kafka
Условия сетевого подключения Kafka
Настройка публичного доступа к Kafka
Доступ к Kafka с использованием VPC Endpoint между VPC
Доступ к Kafka в публичной сети с использованием DNAT
Настройка контроля доступа Kafka
Настройка доступа в открытом или зашифрованном виде к инстансам Kafka
Настройка взаимной SSL-аутентификации для Kafka
Configuring Kafka ACL Users
Настройка клиента Kafka
Настройка параметров для Kafka Clients
Рекомендации по использованию Kafka Client
Подключение к Kafka с помощью клиента (доступ в открытом виде)
Подключение к Kafka с помощью клиента (доступ в зашифрованном виде)
Подключение к Kafka в консоли
Управление сообщениями
Просмотр сообщений Kafka
Изменение периода удержания сообщений Kafka
Удаление сообщений Kafka
Диагностика накопления сообщений Kafka
Управление группами потребителей
Создание группы потребителей Kafka
Запрос списка групп потребителей Kafka
Просмотр информации о потребителях Kafka
Просмотр и сброс Kafka Consumption Offsets
Просмотр Kafka Rebalancing Logs
Изменение описания группы потребителей Kafka
Настройка автоматического создания группы потребителей для Kafka
Экспорт групп потребителей Kafka
Удаление группы потребителей Kafka
Отписка Kafka Consumer Group от темы
Управление квотами
Настройка квот Kafka
Мониторинг квот Kafka
Управление Instances
Просмотр и изменение базовой информации Kafka Instance
Просмотр использования диска Kafka
Viewing Kafka Background Tasks
Просмотр примера кода производства и потребления Kafka
Изменение параметров конфигурации Kafka Instance
Настройка Kafka Instance Tags
Настройка Kafka Recycling Policies
Обновление ядра Kafka Instance
Экспорт списка Kafka Instance
Перезапуск Kafka Instance
Удаление Kafka Instances
Использование Kafka Manager
Доступ к Kafka Manager
Сброс пароля Kafka Manager
Перезапуск Kafka Manager
Отключение Kafka Manager
Изменение спецификаций Instance
Изменение спецификаций Cluster Kafka Instance
Миграция данных
Kafka Обзор миграции данных
Использование MirrorMaker для синхронизации данных между кластерами
Подача заявки на увеличение квот Kafka
Мониторинг и Алерты
Просмотр метрик Kafka
Метрики Kafka
Настройка правила тревоги Kafka
Просмотр журналов аудита Kafka
FAQs
Instances
Почему нельзя выбрать две AZ?
Почему я не могу просмотреть информацию о Subnet и Security Group при создании DMS Instance?
Как выбрать Storage Space для Kafka Instance?
Как выбрать между High I/O и Ultra-high I/O?
Какую политику порога ёмкости следует использовать?
Какие версии Kafka поддерживаются?
Какой адрес ZooKeeper у Kafka Instance?
Находятся ли Kafka Instances в режиме Cluster Mode?
Могу ли я изменить порт для доступа к Kafka Instance?
Каков срок действия сертификатов Kafka SSL?
Как синхронезировать данные из одного Kafka instance в другой?
Как изменить параметр SASL_SSL у Kafka Instance?
Как изменить механизм SASL?
Будет ли Kafka Instance перезапущен после изменения его Enterprise Project?
Развернут ли Kafka Brokers и ZooKeeper на одной VM или на разных VM?
Какие наборы шифров поддерживает Kafka?
Могу ли я изменить Single-AZ Deployment на Multi-AZ Deployment для Instance?
Поддерживает ли DMS for Kafka Cross-AZ Disaster Recovery? Где можно проверить, находится ли существующий instance Across-AZs?
Поддерживают ли Kafka Instances шифрование диска?
Можно ли изменить VPC и Subnet после создания Kafka Instance?
Где можно найти примеры использования Kafka Streams?
Могу ли я обновить Kafka Instances?
Как снова привязать EIP?
Почему самые ранние сообщения не удаляются автоматически, когда ёмкость диска достигает 95%?
Модификация спецификации
Влияет ли изменение спецификации на сервисы?
Будет ли задействована миграция данных при увеличении спецификаций?
Почему при масштабировании происходит сбой производства сообщений?
Что я могу сделать, если не удалось увеличить характеристики из‑за недостаточных ресурсов?
Connections
Как выбрать и настроить security group?
Могу ли я получить доступ к Kafka Instance через публичную сеть?
Сколько адресов подключения имеет экземпляр Kafka по умолчанию?
Поддерживают ли Kafka Instances кросс-региональный доступ?
Поддерживают ли Kafka Instances Cross-VPC Access?
Поддерживают ли Kafka Instances доступ между подсетями?
Поддерживает ли DMS for Kafka аутентификацию с Kerberos?
Поддерживает ли DMS for Kafka доступ без пароля?
Как получить публичный адрес доступа после включения публичного доступа?
Поддерживает ли DMS for Kafka аутентификацию на клиентах со стороны сервера?
Могу ли я использовать PEM SSL Truststore при подключении к Kafka Instance с включённым SASL_SSL?
В чем различия между сертификатами JKS и CRT?
Какую версию TLS поддерживает DMS for Kafka?
Существует ли ограничение на количество клиентских подключений к экземпляру Kafka?
Сколько соединений разрешено от каждого IP-адреса?
Могу ли я изменить адреса частной сети Kafka Instance?
Используется ли один и тот же SSL Certificate для разных Instances?
Почему не рекомендуется использовать клиент Sarama для обмена сообщениями?
Темы и разделы
Есть ли ограничение на количество тем в Kafka Instance?
Почему количество разделов ограничено?
Могу ли я уменьшить количество разделов?
Почему не удаётся создать темы?
Поддерживают ли Kafka Instances пакетный импорт тем или автоматическое создание тем?
Могу ли я просмотреть используемое дисковое пространство темой?
Можно ли добавить ACL Permissions для тем?
Что делать, если место для хранения Kafka заполнено, потому что полученные сообщения не удаляются?
Как увеличить количество разделов?
Будет ли Kafka Instance перезапущен после изменения его Automatic Topic Creation Setting?
Что я могу сделать, если потребитель не может получить сообщения из темы из‑за недостаточных прав?
Могу ли я приобрести разделы отдельно?
Почему сообщения накапливаются и не потребляются в новой партиции темы?
Группы потребителей
Нужно ли мне создавать Consumer Groups, Producers и Consumers для Kafka Instances?
Будет ли Consumer Group без Active Consumers автоматически удалён через 14 дней?
Почему удалённая группа потребителей всё ещё существует?
Почему я не могу просматривать Consumers, когда Instance Consumption находится в норме?
Могу ли я удалить ненужные темы в Consumer Group?
Почему группы потребителей отсутствуют?
Messages
Каков максимальный размер сообщения, которое можно создать?
Почему опрос сообщений часто завершается неудачей во время ребалансировки?
Почему я не могу выполнить запрос сообщений в Console?
Что можно сделать, если сообщения Kafka накопились?
Почему сообщения всё ещё существуют после истечения периода удержания?
Поддерживают ли Kafka Instances доставку отложенных сообщений?
Как просмотреть количество накопленных сообщений?
Почему время создания сообщения отображается как 1970 год?
Как изменить message.max.bytes?
Почему смещения не являются непрерывными?
Kafka Manager
Могу ли я настроить учетную запись Kafka Manager как Read-Only?
Почему я не вижу Broker Information после входа в Kafka Manager?
Yikes! Insufficient partition balance when creating topic : projectman_project_enterprise_project Try again.
Могу ли я выполнить запрос к телу сообщения, используя Kafka Manager?
Могу ли я изменить порт Kafka Manager Web UI?
Какие конфигурации топика можно изменить в Kafka Manager?
Почему информация, отображаемая в Kafka Manager, не соответствует данным мониторинга Cloud Eye?
Как изменить лидера раздела для темы в Kafka Manager?
Почему версия в консоли отличается от версии в Kafka Manager?
Почему инстанс содержит Default Topics __trace и __consumer_offsets?
Почему я вижу удалённую группу потребителей в Kafka Manager?
Monitoring & Alarm
Почему я не могу просмотреть данные мониторинга?
Почему контролируемое количество накопленных сообщений не совпадает с количеством сообщений, отображаемым в Kafka Console?
Почему группа потребителей всё ещё отображается на странице мониторинга после удаления?
Почему Disk Read/Write Traffic и Average Disk Read/Write Duration время от времени колеблются, когда Production/Consumption Traffic низки?
Почему использование JVM Heap Memory Usage of JVM значительно колеблется?
Почему Production Rate всё ещё 0, когда есть произведённые сообщения?
Почему Consumption Rate отображается как 0?
Почему количество накопленных сообщений в Consumer Offset отличается от значения в Monitoring?
Устранение неполадок
Устранение исключений подключения к Kafka
Устранение неполадок 6‑минутной задержки между созданием сообщения и получением
Устранение сбоев создания сообщений
Устранение неполадок при удалении темы
Устранение неполадок входа в Kafka Manager в Windows
Устранение ошибки "Topic {{topic_name}} not present in metadata after 60000 ms" при производстве или потреблении сообщений
Сбой отправки прогресса потребления в Flink 1.15
Тарификация
Поддержка
Юридические документы
Политика конфиденциальности
© 2026 Cloud.ru