Управление топиком

Создать топик

Инструкция приведена на примере веб-интерфейса AKHQ версии 0.26.0.

Важно

После создания топика нельзя изменить срок хранения сообщений и уменьшить количество разделов.

1. Подключитесь к Serverless Queue.
2. Перейдите в раздел Topics.
3. Нажмите кнопку Create a topic.
4. Задайте параметры топика:

   • Name — введите имя топика.
   • Partition — укажите количество разделов топика. Если значение не указано, применится параметр брокера num.partitions.
   • Replicator Factor — этот параметр относится к недоступным для изменения, поэтому вне зависимости от выбора применится значение 1.
   • Cleanup Policy — этот параметр относится к недоступным для изменения, поэтому вне зависимости от выбора применится политика Delete (сообщения будут удаляться по времени).
   • Retention — укажите срок хранения сообщений в топике.
5. Нажмите кнопку Create.

Записать сообщение в топик

Инструкция приведена на примере веб-интерфейса AKHQ версии 0.26.0.

1. Подключитесь к Serverless Queue.
2. Перейдите в раздел Topics.
3. Перейдите в нужный топик и нажмите кнопку Produce to topic.
4. Задайте параметры сообщения:

   • Topic — убедитесь, что выбран нужный топик.
   • Partition — укажите номер раздела. Если оставить значение auto assign, будет выбран раздел на основе ключа или по очереди.
   • (опционально) Key — добавьте ключ сообщения. Все сообщения с одинаковым значением ключа попадут в один раздел. Если ключ не указать, сообщения будут распределяться поочередно по всем разделам.
   • (опционально) Header — добавьте метаданные сообщения в формате «ключ-значение». Например, contentType: application/json.
   • (опционально) Tombstone — включите опцию, чтобы отправить маркер удаления. Поле Value станет недоступно, а сообщение будет записано со значением null.
   • (опционально) Multi message — включите опцию, если хотите отправить несколько сообщений сразу.
   • Value — введите сообщение. Чтобы отправить несколько сообщений сразу, при включенной опции Multi message передайте список сообщений через разделитель или в виде JSON-массива.
5. Нажмите кнопку Produce.

Сообщение будет отправлено в топик и отобразится на вкладке Data.

Прочитать сообщение из топика

Без группы потребителей

Чтение без группы не сохраняет смещения, оно подходит для отладки или мониторинга.

Инструкция приведена на примере веб-интерфейса AKHQ версии 0.26.0.

1. Подключитесь к Serverless Queue.
2. Перейдите в раздел Topics.
3. Перейдите в нужный топик и на вкладку Data.

На вкладке по умолчанию отображаются последние 100 сообщений. Чтобы читать с начала, нажмите Live Tail → Pause и используйте ползунок или кнопку Go to beginning.

В составе группы потребителей

Чтение сообщений выполняется только приложением, использующим Kafka-клиент. Для этого в конфигурации должен быть указан идентификатор группы group.id. Группа потребителей создается автоматически при первом подключении такого приложения.

В веб-интерфейсе AKHQ доступно управление смещениями и мониторинг состояния группы.

Изменить конфигурацию топика

Инструкция приведена на примере веб-интерфейса AKHQ версии 0.26.0.

1. Подключитесь к Serverless Queue.
2. Перейдите в раздел Topics.
3. Перейдите в нужный топик и на вкладку Configs.
4. Измените нужные параметры топика.
5. Нажмите кнопку Update configs.

Новые настройки применятся к топику. Изменения отобразятся на вкладке Configs.

Удалить топик

Инструкция приведена на примере веб-интерфейса AKHQ версии 0.26.0.

Внимание

Все обработанные и необработанные сообщения в топике будут удалены вместе с ним. Все сообщения, поступающие в топик в момент удаления, не будут записаны.

1. Подключитесь к Serverless Queue.
2. Перейдите в раздел Topics.
3. Нажмите на иконку удаления для удаляемого топика.
4. Подтвердите удаление.

Вместе с топиком удалятся все сообщения и связанные с ними смещения.