Облачная платформаEvolution

Посмотреть параметры топика


  1. В списке кластеров Managed Kafka нажмите на название кластера.

  2. Перейдите на вкладку Топики.

  3. Выберите топик и нажмите на название.

Откроется таблица параметров топика Apache Kafka®, которыми можно управлять с помощью интерфейса:

Параметр

Тип

Описание

cleanup.policy

list

Политика хранения сообщений лога в топике.

Возможные значения:

  • delete — удалять старые сегменты по истечении времени хранения или при достижении лимита размера.

  • compact — применять сжатие лога, сохраняя только последнее значение для каждого ключа.

  • delete,compact — комбинированный подход: удалять старые сегменты, а оставшиеся сжимать.

По умолчанию — delete.

compression.type

string

Кодек, используемый для сжатия сообщений.

Возможные значения: uncompressed, zstd, lz4, snappy, gzip, producer.

По умолчанию — producer.

delete.retention.ms

long

Время в миллисекундах, в течение которого хранятся tombstone-маркеры удаления для топиков со сжатым логом. Применяется, если для cleanup.policy выбрано compact или delete,compact.

Диапазон: от 0 до 9223372036854775807.

По умолчанию — 86400000.

file.delete.delay.ms

long

Задержка в миллисекундах перед удалением файла из файловой системы.

Диапазон: от 0 до 9223372036854775807.

По умолчанию — 60000.

flush.messages

long

Количество сообщений топика, которое может накопиться в памяти прежде, чем они будут записаны на диск.

Диапазон: от 1 до 9223372036854775807.

По умолчанию — 9223372036854775807.

flush.ms

long

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

Диапазон: от 0 до 9223372036854775807. Значение 0 отключает автоматический сброс буфера по времени.

По умолчанию — 9223372036854775807.

index.interval.bytes

int

Частота добавления записей в индекс сообщений. Определяет, через сколько байт в логе создается новая индексная запись для быстрого поиска сообщений.

Диапазон: от 0 до 2147483647.

По умолчанию — 4096.

max.compaction.lag.ms

long

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

Диапазон: от 1 до 9223372036854775807.

По умолчанию — 9223372036854775807.

max.message.bytes

int

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

Диапазон: от 0 до 2147483647. Значение 0 означает отсутствие ограничений.

По умолчанию — 1048588.

min.compaction.lag.ms

long

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

Диапазон: от 0 до 9223372036854775807.

По умолчанию — 0.

min.insync.replicas

int

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

Диапазон: от 1 до количества хостов-брокеров в кластере.

По умолчанию — 1.

preallocate

boolean

Предварительное выделение места на диске для файла сегмента лога:

  • true — выделять место при создании нового сегмента.

  • false — выделять место по мере заполнения.

По умолчанию — false.

retention.bytes

long

Максимальный размер раздела в байтах. Если размер превышен, начинается удаление старых сегментов лога. Применяется, если для cleanup.policy выбрано delete.

Диапазон: от -1 до 9223372036854775807. Значение -1 означает отсутствие ограничений.

По умолчанию — -1.

retention.ms

long

Максимальное время хранения файла сегмента лога в миллисекундах. По истечении этого времени сегмент будет удален. Применяется, если для cleanup.policy выбрано delete.

Диапазон: от -1 до 9223372036854775807. Значение -1 означает отсутствие ограничений.

По умолчанию — 604800000.

segment.bytes

int

Размер файла-сегмента лога в байтах.

Диапазон: от 1048576 до 2147483647.

По умолчанию — 1073741824.

segment.ms

long

Период времени в миллисекундах, по истечении которого создается новый файл-сегмент лога, даже если текущий сегмент не заполнен до конца.

Диапазон: от 1 до 9223372036854775807.

По умолчанию — 604800000.

unclean.leader.election.enable

boolean

Поведение при выборе лидера раздела, если все синхронизированные реплики недоступны:

  • true — разрешить выбор лидера из несинхронизированных реплик. Это может привести к потере данных.

  • false — запретить. Раздел станет недоступен до восстановления синхронизированной реплики.

По умолчанию — false.

Вы можете изменять значение параметров, а также отслеживать историю изменений.