Виджет отображает данные о топиках Kafka.

Для каждого топика доступно:

  • Общая информация о топике: основные параметры, конфигурация и статус.
  • Информация о разделах: лидер, смещения и количество реплик.
  • Информация о потребителях: активные потребители, их группы, текущие смещения и отставание.
  • Содержимое сообщений топика.
  • Поиск сообщений по временной метке и смещению.
  • Конфигурация топика в виде таблицы «ключ — значение».

Конфигурация

НазваниеОбязательностьОписаниеЗначение по умолчанию
URLДаURL кластера Kafka—
Протокол аутентификацииНетПротокол для подключения к Kafka. Описание security.protocolPLAINTEXT
Механизм SASLНетМеханизм аутентификации SASL. Обязателен при использовании протокола SASL_PLAINTEXT или SASL_SSL. Описание механизма SASLPLAIN
Пользователь KafkaНетИмя пользователя учётной записи для взаимодействия с Kafka. Нужно для протоколов SASL_PLAINTEXT и SASL_SSL—
ПарольНетПароль учётной записи для взаимодействия с Kafka. Нужен для протоколов SASL_PLAINTEXT и SASL_SSL—
Включить действия виджетаНетПоказывает действия виджета: создание и удаление топиков, отправку сообщений и очистку топикаtrue
Топики KafkaНетНазвание топика или регулярное выражение для фильтрации отображаемых топиков в виджете. Если значение не задано, отображаются все доступные пользователю топики—

Дополнительные возможности виджета

Если включён параметр «Включить действия виджета», виджет позволяет:

  • создавать новые топики;
  • удалять существующие топики;
  • отправлять сообщение в топик;
  • очищать топик от сообщений.

Аутентификация

Виджет подключается к Kafka с учётной записью, указанной в полях «Пользователь Kafka» и «Пароль». Эти поля нужны для протоколов SASL_PLAINTEXT и SASL_SSL.

Поддерживаются протоколы аутентификации:

  • PLAINTEXT;
  • SASL_PLAINTEXT;
  • SASL_SSL.

Для протоколов SASL_PLAINTEXT и SASL_SSL поддерживаются механизмы SASL:

  • PLAIN;
  • SCRAM-SHA-256;
  • SCRAM-SHA-512.

Доступность информации в виджете определяется уровнем прав подключённой учётной записи.