Kafka3ConnectionService¶
描述¶
为生产者或使用者运营提供和管理与 Kafka 代理的连接。
属性¶
下表列出了各项属性，其中带星号 (*) 的为必需属性。其他属性视为可选属性。该表还指出了所有默认值以及属性是否支持 NiFi 表达式语言。
显示名称 |
API 名称 |
默认值 |
允许值 |
描述 |
|---|---|---|---|---|
SSL Context Service |
SSL Context Service |
支持与 Kafka 代理 SSL 通信的服务 |
||
确认等待时间 * |
ack.wait.time |
5 秒 |
向 Kafka 发送消息后，这表示服务等待来自 Kafka 的响应的时间。如果 Kafka 未在此时间段内确认该消息，则该服务将引发异常。 |
|
引导服务器 * |
bootstrap.servers |
以逗号分隔的 Kafka 引导服务器列表，格式为 host:port。对应 Kafka bootstrap.servers 属性 |
||
客户端超时 * |
default.api.timeout.ms |
60 秒 |
Kafka 客户端操作的默认超时时间。映射到 Kafka default.api.timeout.ms。Kafka request.timeout.ms 属性源自已配置超时时间的一半 |
|
事务隔离级别 * |
isolation.level |
read_committed |
|
指定服务在与 Kafka 通信时应如何处理事务隔离级别。未提交选项意味着消息一写入 Kafka 就会被接收，但即使生产者取消了事务，也会被提取。已提交选项将服务配置为不接收生产者事务被取消的任何消息，但这可能会导致一些延迟，因为使用者必须等待生产者完成整个事务，而不是在消息可用时才提取。对应 Kafka isolation.level 属性。 |
元数据最长等待时间 * |
max.block.ms |
5 秒 |
发布者在调用“send”时，为获取元数据或等待缓冲区刷新所等待的最长时间，超过该时间后，整个“send”调用将失败。对应 Kafka max.block.ms 属性 |
|
最大轮询记录数 * |
max.poll.records |
10000 |
Kafka 在单次轮询中应返回的最大记录数。 |
|
SASL 机制 * |
sasl.mechanism |
GSSAPI |
|
用于身份验证的 SASL 机制。与 Kafka 客户端的“sasl.mechanism”属性相对应 |
SASL 密码 * |
sasl.password |
使用 PLAIN 或 SCRAM SASL 机制时随配置的用户名提供的密码 |
||
SASL 用户名 * |
sasl.username |
使用 PLAIN 或 SCRAM SASL 机制时随配置的密码提供的用户名 |
||
安全协议 * |
security.protocol |
PLAINTEXT |
|
用于与代理通信的安全协议。与 Kafka 客户端的“security.protocol”属性相对应 |
状态管理¶
此组件不存储状态。
受限¶
此组件不受限制。
系统资源注意事项¶
此组件未指定系统资源注意事项。