Kafka 样例工程配置文件说明
Conf目录个各配置文件及重要参数配置说明
- Producer API配置项
参数 |
描述 |
备注 |
---|---|---|
security.protocol |
安全协议类型 |
生产者使用的安全协议类型,当前Kerberos开启的模式下仅支持SASL协议,需要配置为SASL_PLAINTEXT。Kerberos未开启的模式下配置为PLAINTEXT。 |
kerberos.domain.name |
域名 |
MRS服务集群的Kerberos域名,未开启Kerberos认证的集群无需配置。 |
sasl.kerberos.service.name |
服务名 |
Kafka集群运行,所使用的Kerberos用户名(需配置为kafka)。未开启Kerberos认证的集群无需配置。 |
- Consumer API配置项
参数 |
描述 |
备注 |
---|---|---|
security.protocol |
安全协议类型 |
消费者使用的安全协议类型,当前安全模式下Kerberos开启的模式下仅支持SASL协议,需要配置为SASL_PLAINTEXT。Kerberos未开启的模式下配置为PLAINTEXT。 |
kerberos.domain.name |
域名 |
MRS服务集群的Kerberos域名,未开启Kerberos认证的集群无需配置。 |
group.id |
消费者的group id |
- |
auto.commit.interval.ms |
是否自动提交offset |
布尔值参数,默认值为true |
sasl.kerberos.service.name |
服务名 |
Kafka集群运行,所使用的Kerberos用户名(需配置为kafka)。未开启Kerberos认证的集群无需配置。 |
- 客户端信息配置项
参数 |
描述 |
备注 |
---|---|---|
metadata.broker.list |
元数据Broker地址列表 |
通过此参数值,创建与元数据Broker之间的连接,需要直接访问元数据的API需要用到此参数。访问端口仅支持不开启Kerberos模式下的端口,端口说明详见Kafka安全接口介绍 |
kafka.client.zookeeper.principal |
kafka集群访问zookeeper的认证和域名 |
- |
bootstrap.servers |
Broker地址列表 |
通过此参数值,创建与Broker之间的连接。端口配置项详见Kafka安全接口介绍 |
zookeeper.connect |
zookeeper地址列表 |
通过此参数,访问zookeeper,末尾需要带上kafka服务名kafka |
- MRS服务是否开启Kerberos认证配置项
参数 |
描述 |
备注 |
---|---|---|
kafka.client.security.mode |
kafka所在的MRS服务集群是否开启Kerberos认证配置项 |
若开启了Kerberos认证,设置为yes,否则设置为no。 |