Опции подключений PXF

KAFKA_ADMIN_CONNECTION_TIMEOUT

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

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

TOPIC_AUTO_CREATE_FLAG

Необходимость автоматического создания топика в Kafka. Топик будет создан с одной партицией и фактором репликации 1.

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

AVRO_DEFAULT_DECIMAL_SCALE

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

Значение по умолчанию: 18. Не должно превышать значение AVRO_DEFAULT_DECIMAL_PRECISION.

SECURITY_PROTOCOL

Протокол соединения с брокерами Kafka.

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

• PLAINTEXT — по умолчанию;

• SASL_PLAINTEXT — аутентификация SASL без шифрования;

• SASL_SSL — аутентификация SASL по протоколу SSL;

• SSL — односторонняя и двусторонняя аутентификация.

TRUCTSTORE_LOCATION

Путь к truststore-файлу.

—

KEYSTORE_LOCATION

Путь к keystore-файлу.

—

KERBEROS_SERVICE_NAME

Имя Kerberos-принципала, используемого Kafka.

—

KERBEROS_PRINCIPAL

Имя принципала Kerberos, которое может быть как именем пользователя, так и названием сервиса.

—

KERBEROS_USE_KEYTAB

Необходимость получения секретного ключа принципала из keytab.

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

KERBEROS_USE_TICKET_CACHE

Необходимость получения TGT (ticket-granting ticket) из кеша тикетов.

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

JAAS_CONFIG_FILE

Путь к конфигурационному файлу JAAS.

—

SASL_USER

Имя пользователя для клиентских подключений.

—

SASL_USER_CONFIG_FILE

Путь к конфигурационному файлу JAAS.

—

connection.property.createDatabaseIfNotExist

Добавление соединения JDBC с базой данных PostgreSQL.

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

statement.batchSize

Количество строк для записи во внешнюю таблицу базы за один батч.

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

statement.writeSize

Количество строк для группировки в пакет перед записью во внешнюю таблицу базы данных.

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

read.prepared-statement

Использование PreparedStatement вместо Statement при чтении данных из внешнего источника.

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

pool.enabled

Пул подключений для конфигурации JDBC-сервера.

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

pool.property.connectionTimeout

Максимальное время ожидания подключения из пула в миллисекундах.

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

pool.property.minimumIdle

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

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

session.property.search_path

Установка свойства search_path на уровне сессии.

Значение свойства.

connection.property.SSLTrustStorePath

Путь к truststore-файлу.

—

distribution

Тип распределения нагрузки между хостами ClickHouse.

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

• LIST — хост выбирается случайным образом из списка, указанного в опции url. Значение по умолчанию.

• GPREQUEST — хост выбирается из списка хостов, возвращенного запросом gp_request, с использованием алгоритма round-robin.

gp_user

Имя пользователя Managed ArenadataDB для выполнения запроса gp_request.

—

lines_batch_size

Максимальное количество строк в батче данных, отправляемых в Clickрouse со стороны коннектора.

Целое положительное число. Значение по умолчанию: 100000.

send_compressed

Использование сжатия данных на стороне коннектора перед отправкой в ClickHouse.

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

insert_distributed_sync

Режим синхронного добавления данных в распределенные таблицы.

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

• true — данные вставляются синхронно, запрос INSERT считается выполненным успешно, когда все данные записаны на все шарды. Значение по умолчанию.

• false — данные вставляются асинхронно.