Рабочее место администратора¶
Обработка «Кафка: Администрирование» — инструмент управления кластером Kafka прямо из 1С: состояние брокеров, темы и их конфигурации, группы получателей, пользователи SCRAM и правила доступа. Отдельная консоль администратора Kafka для повседневных задач не нужна.
Обработка открывается по роли «Кафка: Администрирование» из подсистемы «Кафка».
В шапке выбирается кластер, с которым идёт работа, и выводятся версии подсистемы и шлюза. Отображаемая версия шлюза — самая быстрая проверка того, что связь с ним есть.
Права определяются учётной записью Kafka
Все операции выполняются от имени пользователя, указанного в настройках кластера. Если брокеры используют ACL, доступный набор действий ограничен правами этой учётной записи, а не ролью в 1С.
Кластер¶
Свойства — идентификатор кластера и его контроллер.
Узлы — брокеры кластера: идентификатор, сервер, порт, стойка. Для выбранного брокера доступны:
- Конфигурация — параметры брокера с признаками «только чтение» и «значение по умолчанию»;
- Каталоги — каталоги журналов с их размером и ошибками, а по каждому каталогу — реплики разделов: тема, раздел, размер, отставание, признак будущей реплики.
Темы¶
Список тем кластера с командами обновления, создания и удаления. Для выбранной темы открываются закладки:
| Закладка | Содержимое |
|---|---|
| Описание | имя, идентификатор, признак внутренней темы |
| Разделы | разделы, их лидеры и реплики; здесь же создаются дополнительные разделы |
| Конфигурация | параметры темы: изменение значения и сброс к значению по умолчанию |
| Смещения | начальные и конечные смещения разделов |
| Данные | просмотр сообщений темы |
| Отправители | активные отправители, пишущие в разделы темы |
| Разрешённые операции | операции, доступные текущей учётной записи |
Разделы добавляются, но не убираются
Kafka позволяет только увеличивать число разделов темы. Уменьшить его нельзя — можно лишь удалить и создать тему заново, потеряв её содержимое. Кроме того, добавление разделов меняет распределение сообщений по ключу: сообщения с одним ключом, записанные до и после, могут оказаться в разных разделах.
Просмотр сообщений¶
Закладка «Данные» показывает первые или последние сообщения темы — по заданному количеству на каждый раздел. Для каждого сообщения выводятся раздел, смещение, момент времени, ключ, значение и заголовки.
Просмотр не влияет на обмен: он выполняется отдельным получателем с выключенной автофиксацией, поэтому позиции чтения остаются нетронутыми.
Группы¶
Список групп кластера с типом и состоянием. Kafka различает несколько типов групп; подсистема показывает описание для каждого — classic, consumer, share, streams.
Для групп получателей (classic и consumer) доступны:
- состав участников с назначенными им разделами;
- позиции группы по темам и разделам — с возможностью изменить или удалить позицию;
- удаление отдельных статических участников или всех сразу;
- удаление группы целиком.
Изменение позиций группы влияет на чужие обмены
Правка позиции группы — это перемотка чтения для всех, кто читает тему в этой группе. Убедитесь, что группа не используется работающим сейчас обменом. Позиции автоматического обмена подсистемы в группах Kafka не хранятся — они ведутся в информационной базе.
SCRAM-пользователи¶
Список учётных записей SCRAM с механизмом и количеством итераций. Доступны добавление, изменение пароля и удаление. Это те самые учётные данные, которые указываются в настройках кластера для аутентификации подсистемы.
Контроль доступа¶
Правила ACL: фильтр по типу ресурса, имени и типу шаблона, чтение действующих правил и запись новых. Позволяет выдать учётной записи 1С права на нужные темы и группы, не обращаясь к консоли Kafka.