Параметр kafka_settings#

Группа параметров kafka_settings предназначена для конфигурирования librdkafka.

Название

Обязательность

Описание

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

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

settings

Опциональный

—

Последовательность параметров и их значения

—

settings.brokers

Обязательный

Список брокеров Kafka. Для разделения значений используется знак «,»

Текстовое значение

—

settings.client_id

Опциональный

Идентификатор клиента Kafka

Текстовое значение

—

settings.compression

Опциональный

Формат сжатия сообщений

none, gzip, snappy, lz4, zstd

snappy

settings.partition

Опциональный

Идентификатор раздела

Текстовое значение

Раздел автоматически назначается в соответствии с идентификатором сообщения

settings.partitioner

Опциональный

Partitioner для доставки сообщения

random, consistent, consistent_random, murmur2, murmur2_random, fnv1a, fnv1a_random

—

settings.log_level

Опциональный

Уровень логирования

Целочисленное значение: min 0, max 7

6

settings.max_retries

Опциональный

Максимальное количество попыток отправки неудачных MessageSet. Повторная попытка подразумевает переупорядочивание

Целочисленное значение: min 0, max 10000000

—

settings.buffer_max_messages

Опциональный

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

Целочисленное значение: min 0, max 10000000

100000

settings.backoff

Опциональный

Временной интервал отсрочки передачи в миллисекундах

Целочисленное значение: min 0, max 3600000

100

settings.compression_level

Опциональный

Уровень компрессии

Целочисленное значение: min -1, max 12

—

settings.message_max_bytes

Опциональный

Максимальный размер сообщения запроса по протоколу Kafka

Целочисленное значение: min 1000, max 1000000000

1000000

settings.message_copy_max_bytes

Опциональный

Максимальный размер сообщения, которое будет скопировано в буфер

Целочисленное значение: min 1000, max 1000000000

65535

settings.message_timeout

Опциональный

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

Целочисленное значение: min 0, max 900000

300000

settings.topic_metadata_refresh_interval

Опциональный

Временной интервал в миллисекундах, в течение которого происходит обновление данных в topic и брокере

Целочисленное значение: min -1, max 3600000

300000

settings.ssl_endpoint_identification_algorithm

Опциональный

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

none, https

—

settings.ssl_certificate_verification

Опциональный

Вкл./Откл. верификацию сертификата

Логическое значение

on

settings.debug

Опциональный

Вкл./Откл. журналирование уровня debug

Логическое значение

—

settings.ssl

Опциональный

Вкл./Откл. поддержку ssl/tls

Логическое значение

—

settings.ssl_keystore

Опциональный

Путь к хранилищу ключей клиента, используемых для аутентификации. Используется, если ssl is not None

Текстовое значение

—

settings.ssl_keystore_pwd

Опциональный

Название файла с паролем для хранилища ключей. Используется, если ssl is not None

Текстовое значение

—

settings.ssl_cert

Опциональный

Файл или путь расположения сертификата. Используется, если ssl is not None

Текстовое значение

—

settings.ssl_ca

Опциональный

Файл или путь расположения клиентского сертификата CA. Используется, если ssl is not None

Текстовое значение

—

settings.ssl_key

Опциональный

Расположение ключа сертификата CA. Используется, если ssl is not None

Текстовое значение

—

settings.ssl_key_pwd

Опциональный

Пароль от приватного ключа. Используется, если ssl is not None

Текстовое значение

—

settings.ssl_ciphers

Опциональный

Набор шифров, разрешенных для запроса. Используется, если ssl is not None

Текстовое значение

—

settings.ssl_curves

Опциональный

Поддерживаемое расширение для кривых. Используется, если ssl is not None

Текстовое значение

—

settings.ssl_sigalsgs

Опциональный

Расширения алгоритма подписи, допустимых к использованию сервером пар подпись/алгоритм хеширования. Используется, если ssl is not None

Текстовое значение

—

settings.ssl_crl

Опциональный

Путь к CRL для проверки действительности сертификата брокера. Используется, если ssl is not None

Текстовое значение

—