火山引擎消息队列 Kafka版为您提供示例项目 Demo 供您快速接入和体验。本文介绍配置文件 config.properties的常用参数配置。
下载 Demo 并解压缩到本地后，在路径 {DemoPath}/src/main/resources 中查看配置文件模板 config.properties 和 ssl.config.properties。
说明
实际场景下填写配置文件时，应删除所有注释语句。
## 接入点，通过控制台获取 bootstrap.servers=xxxxx // 安全协议: PLAINTEXT, SASL_PLAINTEXT security.protocol=PLAINTEXT topic=my-topic consumer.group.id=test consumer.auto.offset.reset=earliest consumer.enable.auto.commit=false client.dns.lookup=use_all_dns_ips // 客户端认证机制: PLAIN, SCRAM-SHA-256 sasl.mechanism=PLAIN sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="xxxx" password="xxxxx"; #org.apache.kafka.common.security.scram.ScramLoginModule required username="xxxx" password="xxxxx";
参数名称 | 是否必选 | 默认值 | 描述 |
|---|---|---|---|
bootstrap.servers | 必选 | kafka-xx.kafka.ivolces.com:xxxx | Kafka 实例的接入点。 |
security.protocol | 可选 | PLAINTEXT | Kafka 实例接入点的信道认证机制。
|
topic | 必选 | topictest | 消息发送与接收的 Topic 名称。 |
consumer.group.id | 必选 | grouptest | 消费消息时，指定的消费组名称。建议取业务相关的名称，便于区分。消费组可用于实现广播和单播的能力。正常情况下，一条消息只会被一个消费组消费一次，但是可以被多个消费组消费多次。 |
consumer.auto.offset.reset | 可选 | earliest | 当消费组没有合法的消费记录时，使用此配置对消费进度进行重置。例如：服务侧未找到消费组的消费记录或记录的消费进度已失效。
|
consumer.enable.auto.commit | 可选 | true | 是否开启自动提交消费进度。开启后，无需调用消费进度的提交方法也可将消费进度保存到服务侧。 |
sasl.mechanism | 可选 | PLAIN | SASL 认证算法类型，使用 SASL 接入点时必选。
|
sasl.jaas.config | 可选 | SASL 认证信息，包括的账号名和账号密码，使用 SASL 接入点时必选。 说明 请根据客户端认证机制，填写对应类型用户的用户名及密码进行进行 SASL 认证，例如在 PLAIN 机制下使用 PLAIN 用户的用户名及密码。 | |
client.dns.lookup | 可选 | 指定 Kafka 客户端通过 DNS 解析域名的方式。
|