Подключиться
Yandex Managed Service for Apache Kafka®

Метод get

Возвращает информацию об указанном топике Kafka.

Чтобы получить список доступных топиков Kafka, выполните запрос list.

HTTP-запрос

GET https://mdb.api.cloud.yandex.net/managed-kafka/v1/clusters/{clusterId}/topics/{topicName}

Path-параметры

Параметр Описание
clusterId Обязательное поле. Идентификатор кластера Apache Kafka®, к которому принадлежит топик. Чтобы получить идентификатор кластера, выполните запрос list. Максимальная длина строки в символах — 50.
topicName Обязательное поле. Имя запрашиваемого топика Kafka. Чтобы получить имя топика, выполните запрос list. Длина строки в символах должна быть от 1 до 63. Значение должно соответствовать регулярному выражению [a-zA-Z0-9_-]*.

Ответ

HTTP Code: 200 - OK

{
  "name": "string",
  "clusterId": "string",
  "partitions": "integer",
  "replicationFactor": "integer",
  "topicConfig_2_1": {
    "cleanupPolicy": "string",
    "compressionType": "string",
    "deleteRetentionMs": "integer",
    "fileDeleteDelayMs": "integer",
    "flushMessages": "integer",
    "flushMs": "integer",
    "minCompactionLagMs": "integer",
    "retentionBytes": "integer",
    "retentionMs": "integer"
  }
}

Топик Kafka. Подробнее читайте в разделе Concepts → Topics and partitions документации.

Поле Описание
name string

Имя топика.
clusterId string

Идентификатор кластера Apache Kafka®, к которому принадлежит топик.

Чтобы получить идентификатор кластера Apache Kafka®, выполните запрос list.
partitions integer (int64)

Количество разделов в топике.
replicationFactor integer (int64)

Количество копий данных (реплик) для топика в кластере.
topicConfig_2_1 object

Настройки топика.
topicConfig_2_1.
cleanupPolicy		 string

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

  • CLEANUP_POLICY_DELETE: эта политика отбрасывает сегменты лога либо при истечении срока их хранения, либо при достижении предельного размера лога. См. также описание logRetentionMs и других подобных параметров.
  • CLEANUP_POLICY_COMPACT: эта политика сжимает сообщения в логе.
  • CLEANUP_POLICY_COMPACT_AND_DELETE: эта политика использует как сжатие сообщений, так и удаление сегментов лога.
topicConfig_2_1.
compressionType		 string

Тип сжатия для указанного топика.

  • COMPRESSION_TYPE_UNCOMPRESSED: не использовать кодек (сообщения не сжимаются).
  • COMPRESSION_TYPE_ZSTD: кодек Zstandard.
  • COMPRESSION_TYPE_LZ4: Кодек LZ4.
  • COMPRESSION_TYPE_SNAPPY: Кодек Snappy.
  • COMPRESSION_TYPE_GZIP: кодек GZip.
  • COMPRESSION_TYPE_PRODUCER: кодек задается на стороне производителя (допустимые кодеки: ZSTD, LZ4, GZIP или SNAPPY).
topicConfig_2_1.
deleteRetentionMs		 integer (int64)

Время (в миллисекундах), в течение которого нужно хранить tombstone-маркеры удаления для топиков со сжатым логом.
topicConfig_2_1.
fileDeleteDelayMs		 integer (int64)

Время ожидания перед удалением файла из файловой системы.
topicConfig_2_1.
flushMessages		 integer (int64)

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

Эта настройка переопределяет на уровне топика настройку уровня кластера logFlushIntervalMessages.
topicConfig_2_1.
flushMs		 integer (int64)

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

Эта настройка переопределяет на уровне топика настройку уровня кластера logFlushIntervalMs.
topicConfig_2_1.
minCompactionLagMs		 integer (int64)

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

Максимальный размер, до которого может вырасти раздел, прежде чем Kafka начнет отбрасывать старые сегменты лога, если действует настройка delete cleanupPolicy. Эта настройка полезна, если вам необходимо контролировать размер лога из-за ограниченного дискового пространства.

Эта настройка переопределяет на уровне топика настройку уровня кластера logRetentionBytes.
topicConfig_2_1.
retentionMs		 integer (int64)

Количество миллисекунд до удаления файла сегмента лога; в течение этого времени Kafka будет хранить файл сегмента лога.

Эта настройка переопределяет на уровне топика настройку уровня кластера logRetentionMs.
В этой статье: