Если сообщения потеряны или не могут быть потреблены, вы можете запросить содержимое и атрибуты конкретных сообщений для устранения неполадок.
Вы можете просматривать смещение различных разделов, размер сообщения, время создания и тело сообщений в темах.
Примечания и ограничения
- Если тема содержит большой объём данных, при запросе сообщений в теме с единственной репликой может быть возвращена внутренняя ошибка сервиса. Вы можете сократить диапазон времени запроса в зависимости от объёма данных.
- При запросе по содержимому или ключу, из‑за ограничений ресурсов и производительности, можно запросить максимум 200 МБ и 10 000 сообщений, а возвращено может быть не более 10 сообщений.
- При запросе сообщений во всех разделах может быть возвращено не более 500 записей.
- Консоль отображает сообщения размером менее 4 KB. Чтобы просмотреть сообщения размером более 4 KB, нажмите Download Message.
Процедура
- Войдите в консоль.
- Нажмите
в левом верхнем углу, чтобы выбрать регион, в котором находится ваш инстанс. - Нажмите
в левом верхнем углу и выберите Application > Distributed Message Service for Kafka, чтобы открыть список инстансов Kafka. - Нажмите нужный инстанс, чтобы перейти на страницу сведений об инстансе.
- Перейдите на страницу запроса сообщений одним из следующих способов:
- Просмотр сообщений в любой теме: В левой панели навигации выберите Instance > Message Query.
- Просмотр сообщений в конкретной теме: В панели навигации выберите Instance > Topics. Нажмите имя темы, которую нужно запросить. Отображается страница сведений о теме. Нажмите Message Query. Отображается вкладка Message Query.
- Сообщения можно запросить по смещению или времени создания.
- Если известны раздел темы и смещение сообщения, запросите сообщение по смещению. Подробности см. в Table 1.
Table 1Запрос сообщений по смещению Параметр
Описание
Имя темы
Отображается только при выборе Instance > Message Query.
Имя темы, которую нужно запросить.
Раздел
Раздел, в котором находится сообщение.
Смещение
Смещение сообщения.
- Если известен диапазон времени отправки сообщения, но смещение сообщения неизвестно, запросите сообщение по времени создания. Подробности см. в Table 2.
Table 2Запрос сообщений по времени создания Параметр
Описание
Имя темы
Отображается только при выборе Instance > Message Query.
Имя темы для запроса.
Раздел
Раздел, в котором находится сообщение.
Если раздел не указан, сообщения во всех разделах темы отображаются в результате запроса.
Ограничения на запрос сообщений по раздел:
- Запрос во всех разделах: Из‑за ограничений ресурсов и производительности максимальное количество возвращаемых сообщений — 500, а общий размер всех сообщений не может превышать 200 MB.
Процесс получения 500 сообщений: Система последовательно извлекает последние 500 сообщений из каждого раздела (начиная с раздела 0), пока общий размер извлечённых сообщений не превысит 200 MB. Запрошенные сообщения сортируются по времени, и возвращаются последние 500 сообщений.
- Запрос в отдельном разделе: Все сообщения за указанный период времени возвращаются без ограничения в 500 сообщений или 200 MB.
Чтобы запросить больше сообщений, сократить диапазон времени запроса или указать разделы.
Ключ
Введите ключ сообщения, чтобы искать сообщения, содержащие его.
Например, тема содержит два сообщения, ключи которых abc и abcd. Введите "abc" в поле Key. Возвращаются два сообщения.
Query with a key: Из‑за ограничений ресурсов и производительности можно искать не более 10,000 сообщений, а общий размер всех сообщений не может превышать 200 MB. Only 10 messages containing the key возвращаются.
Content
Можно задать несколько условий запроса. Результаты запроса удовлетворяют всем им.
Чтобы задать условие запроса:
Query with content: Из‑за ограничений ресурсов и производительности можно искать не более 10,000 сообщений, а общий размер всех сообщений не может превышать 200 MB. Only 10 messages containing the keyword возвращаются.
Для больших записей (> 20 KB на сообщение) или длительного периода выгрузите сообщения для офлайн‑запроса.
Created
Время создания сообщения. Вы можете задать диапазон времени сообщений для запроса.
WARNING:Если тема содержит большой объём данных, при запросе сообщений в теме с единственной репликой может быть возвращена внутренняя ошибка сервиса. Вы можете сократить диапазон времени запроса в зависимости от объёма данных.
- Запрос во всех разделах: Из‑за ограничений ресурсов и производительности максимальное количество возвращаемых сообщений — 500, а общий размер всех сообщений не может превышать 200 MB.
- Если известны раздел темы и смещение сообщения, запросите сообщение по смещению. Подробности см. в Table 1.
- Нажмите Search для запроса сообщений.
Результат запроса выглядит следующим образом.
Figure 1 Запрос сообщений темы
Table 3 Параметры сообщения Параметр
Описание
Topic Name
Имя темы, в которой находится сообщение.
Partition
Раздел, в котором находится сообщение.
Offset
Позиция сообщения в разделе.
Message Size (Byte)
Размер сообщения.
Created
Время создания сообщения. Время создания сообщения указывается параметром CreateTime, когда продюсер создает сообщения. Если этот параметр не задан при создании сообщения, время создания сообщения по умолчанию равно 1970 году.
- Нажмите View Message Body. В отображаемом View Message Body диалоговом окне просмотрите содержимое сообщения, включая имя темы, раздел, смещение, время создания и тело сообщения.
Консоль отображает сообщения размером менее 4 KB. Чтобы просмотреть сообщения размером более 4 KB, нажмите Download Message.
- (Необязательно) Чтобы восстановить настройки по умолчанию, нажмите Reset.