Kafka3ConnectionService
Описание
Обеспечивает и управляет подключениями к Kafka Brokers для операций с продюсером или потребителем.
Теги
No tags provided.
Свойства
| Название | Описание |
|---|---|
| Bootstrap Servers | Список серверов начальной загрузки Kafka, разделённых запятыми, в формате хост:порт. Соответствует свойству Kafka bootstrap.servers. |
| Security Protocol | Протокол безопасности, используемый для связи с брокерами. Соответствует свойству Kafka Client security.protocol |
| SASL Mechanism | механизм SASL, используемый для аутентификации. Соответствует свойству Kafka Client sasl.mechanism |
| SASL Username | Имя пользователя, предоставляемое с настроенным паролем при использовании ОБЫЧНЫХ или скрытых механизмов SASL. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)This Property is only considered if the [SASL Mechanism] Property is set to one of the following values: [PLAIN], [SCRAM-SHA-512], [SCRAM-SHA-256] |
| SASL Password | Пароль, предоставляемый вместе с настроенным именем пользователя при использовании обычных или скрытых механизмов SASL. Чувствительный параметр: true Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)This Property is only considered if the [SASL Mechanism] Property is set to one of the following values: [PLAIN], [SCRAM-SHA-512], [SCRAM-SHA-256] |
| SSL Context Service | Сервис, поддерживающий SSL-связь с брокерами Kafka |
| Transaction Isolation Level | Specifies how the service should handle transaction isolation levels when communicating with Kafka. |
| The uncommited option means that messages will be received as soon as they are written to Kafka but will be pulled, even if the producer cancels the transactions. | |
| The committed option configures the service to not receive any messages for which the producer's transaction was canceled, but this can result in some latency since the | |
| consumer must wait for the producer to finish its entire transaction instead of pulling as the messages become available. | |
| Corresponds to Kafka isolation.level property. | |
| Max Poll Records | Максимальное количество записей, которые Kafka должен возвращать за один опрос. |
| Client Timeout | Тайм-аут по умолчанию для клиентских операций Kafka. Сопоставляется со свойством Kafka default.api.timeout.ms. Свойство Kafka request.timeout.ms рассчитывается как половина настроенного тайм-аута |
| Max Metadata Wait Time | The amount of time publisher will wait to obtain metadata or wait for the buffer to flush during the 'send' call before failing the |
| entire 'send' call. Corresponds to Kafka max.block.ms property | |
| Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) | |
| Acknowledgment Wait Time | After sending a message to Kafka, this indicates the amount of time that the service will wait for a response from Kafka. |
| If Kafka does not acknowledge the message within this time period, the service will throw an exception. |