更新时间:2024-12-02 GMT+08:00
分享

Kafka 样例工程配置文件说明

Conf目录下各配置文件及重要参数配置说明。

  • Producer API配置项。
    表1 producer.properties文件配置项

    参数

    描述

    备注

    security.protocol

    安全协议类型

    生产者使用的安全协议类型,当前Kerberos开启的模式下仅支持SASL协议,需要配置为SASL_PLAINTEXT。Kerberos未开启的模式下配置为PLAINTEXT。

    kerberos.domain.name

    域名

    MRS服务集群的Kerberos域名,未开启Kerberos认证的集群无需配置。

    sasl.kerberos.service.name

    服务名

    Kafka集群运行,所使用的Kerberos用户名(需配置为kafka)。未开启Kerberos认证的集群无需配置。

  • Consumer API配置项。
    表2 consumer.properties文件配置项

    参数

    描述

    备注

    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认证的集群无需配置。

  • 客户端信息配置项。
    表3 client.properties文件配置项

    参数

    描述

    备注

    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认证配置项。
    表4 kafkaSecurityMode文件配置项

    参数

    描述

    备注

    kafka.client.security.mode

    kafka所在的MRS服务集群是否开启Kerberos认证配置项

    若开启了Kerberos认证,设置为yes,否则设置为no。

  • log4j日志配置项文件log4j.properties

    log4j日志框架的配置文件,默认情况不输入样例工程运行日志。

相关文档