Kafka3ConnectionService Controller Service
描述
为生产者或消费者操作提供并管理与 Kafka Brokers 的连接。
标签
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| 引导服务器 | | 以逗号分隔的 Kafka Bootstrap 服务器列表，格式为主机：端口。 对应于Kafka bootstrap.servers属性 | |
| 安全协议 | SSL |
| 用于与经纪人通信的安全协议。 对应于Kafka Client security.protocol属性 |
| SASL 机制 | GSSAPI |
| 用于身份验证的 SASL 机制。 对应Kafka客户端sasl.mechanism属性 |
| SASL 用户名 | | 使用 PLAIN 或 SCRAM SASL 机制时提供的用户名和配置的密码 支持表达式语言：是（仅使用环境/系统变量求值） | |
| SASL 密码 | | 使用 PLAIN 或 SCRAM SASL 机制时，密码与配置的用户名一起提供 敏感属性：是 支持表达式语言：是（仅使用环境/系统变量求值） | |
| OAuth2 访问令牌提供者服务 | | 控制器服务 API：OAuth2AccessTokenProvidercn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 提供 OAuth2 访问令牌进行身份验证的服务 |
| Kerberos 用户服务 | | 控制器服务 API：SelfContainedKerberosUserServicecn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 支持使用 Kerberos 进行用户身份验证的服务 |
| Kerberos 服务名 | | 与代理 JAAS 配置中配置的 Kafka 服务器的主名称匹配的服务名称 支持表达式语言：是（仅使用环境/系统变量求值） | |
| SSL Context Service | | 控制器服务 API：SSLContextProvidercn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8 | 支持与 Kafka 代理进行 SSL 通信的服务 |
| 事务隔离级别 | read_committed |
| 指定服务在与 Kafka 通信时应如何处理事务隔离级别。uncommitted 选项意味着消息在写入 Kafka 后立即被接收，但如果生产者取消了事务，消息仍会被拉取。committed 选项配置服务不接收生产者事务已取消的任何消息，但这可能导致一些延迟，因为消费者必须等待生产者完成整个事务，而不是在消息可用时立即拉取。对应于 Kafka 的 isolation.level 属性。 |
| Max Poll Records | 10000 | Kafka 在一次轮询中应返回的最大记录数。 | |
| 客户端超时 | 60 sec | Kafka 客户端操作的默认超时。 映射到 Kafka default.api.timeout.ms。 Kafka request.timeout.ms 属性源自配置超时的一半 | |
| 最大元数据等待时间 | 5 sec | 发布者在 'send' 调用期间等待获取元数据或等待缓冲区刷新的时间量，超过此时间将使整个 'send' 调用失败。对应于 Kafka 的 max.block.ms 属性。 支持表达式语言：是（仅使用环境/系统变量求值） | |
| 确认等待时间 | 5 sec | 向 Kafka 发送消息后，这表示服务等待 Kafka 响应的时间量。 如果 Kafka 在此时间段内未确认消息，服务将抛出异常。 |
动态属性
| 名称 | 值 | 描述 |
|---|---|---|
| Kafka 配置属性或 SASL 扩展属性的名称。 | 给定属性的值。 | Kafka 配置属性将在加载任何提供的配置属性后添加到 Kafka 配置中。如果动态属性表示已设置的属性，则其值将被忽略并记录 WARN 消息。有关可用 Kafka 属性的列表，请参阅：http://kafka.apache.org/documentation.html#configuration。SASL 扩展属性可以在 sasl_extension_propertyName 格式（例如 sasl_extension_logicalCluster）。 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
提供的 Service API
KafkaConnectionService