Вернуться наверх

Параметры топика ​

Пользовательские параметры ​

Пользовательские параметры Serverless Queue можно задавать и изменять самостоятельно.

message.timestamp.after.max.ms ​

Максимально допустимая разница в миллисекундах между временной меткой входящего сообщения и текущим временем брокера, если метка сообщения находится в будущем относительно времени брокера.

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

Применяется, если параметр message.timestamp.type имеет значение CreateTime.

Значение по умолчанию: 3600000 (1 час).

message.timestamp.before.max.ms ​

Максимально допустимая разница в миллисекундах между временной меткой входящего сообщения и текущим временем брокера, если метка сообщения находится в прошлом относительно времени брокера.

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

Применяется, если параметр message.timestamp.type имеет значение CreateTime.

Значение по умолчанию: 9223372036854776000 (фактически соответствует отсутствию ограничения).

retention.ms ​

Время в миллисекундах, в течение которого сегменты лога хранятся в топике перед автоматическим удалением, если действует политика очистки лога delete. Ограничивается параметром брокера mws.max.retention.ms.

Значение по умолчанию: 86400000 (1 день).

message.timestamp.type ​

Источник временной метки сообщения:

  • CreateTime — время создания сообщения, указанное производителем;
  • LogAppendTime — время записи, присвоенное брокером.

Значение по умолчанию: CreateTime.

Внутренние параметры ​

Внутренние параметры Serverless Queue недоступны для изменения.

cleanup.policy ​

Политика очистки старых сообщений лога.

Фиксированное значение: delete.

compression.type ​

Кодек формата сжатия при хранении сообщений.

Фиксированное значение: uncompressed.

min.insync.replicas ​

Минимальное количество реплик раздела, которые должны быть в актуальном состоянии (in-sync), чтобы запись считалась успешной.

Фиксированное значение: 1.

retention.bytes ​

Размер раздела в байтах, при превышении которого старые сегменты лога удалятся, если действует политика очистки лога delete.

Фиксированное значение: -1 (ограничений нет).