SDK 配置说明--消息队列 Kafka版-火山引擎

文档中心

导航

SDK 配置说明

最近更新时间：2023.02.27 14:03:37首次发布时间：2023.02.27 14:03:37

火山引擎消息队列 Kafka版为您提供示例项目 Demo 供您快速接入和体验。本文介绍配置文件 config.json 的常用参数配置。

配置文件模板

下载 Demo 并解压缩到本地后，在路径 {DemoPath}/config/config_templete.json 中查看配置文件模板。

{
  "bootstrap.servers": "127.0.0.1:8092",
  "security.protocol": "PLAINTEXT",
  "debug": false,
  "topic": "my-topic",
  "producer": {
    "acks": "1",
    "batch.size": "16384"
  },
  "consumer": {
    "group.id": "test",
    "auto.offset.reset": "earliest",
    "enable.auto.commit": true
  },
  "sasl": {
    "mechanism": "PLAIN",
    "username": "test-user",
    "password": "test-password"
  }
}

参数说明

参数名称	是否必选	默认值	描述
bootstrap.servers	必选	`kafka-****.kafka.ivolces.com:9092`	Kafka 实例的接入点。请在控制台实例详情页面接入点区域中查看接入点信息。
security.protocol	可选	PLAINTEXT	Kafka 实例接入点的信道认证机制。 PLAINTEXT：使用默认接入点。 SASL_PLAINTEXT：使用 SASL 接入点。 SASL_SSL：使用 SASL_SSL 接入点。
debug	可选	false	开启 DEBUG 模式将会输出 Kafka 的运行日志。
topic	必选	topictest	消息发送与接收的 Topic 名称。请在指定实例的Topic管理页签中查看 Topic 信息。
producer.acks	可选	1	生产可靠性配置。 0：Kafka 服务侧不会返回写入结果，不能保证消息写入。 1：服务侧在消息写入一个副本后返回写入成功。 -1：服务侧在消息写入所有同步副本后返回写入成功。按照 [0, 1, -1] 的配置顺序，性能依次下降，可靠性依次增加。
producer.batch.size	可选	16384	批量发送消息的大小。在客户端消息较大或者客户端消息发送较快时可考虑加大此值。
consumer.group.id	必选	group-xxxxxxxx	消费消息时，指定的消费组名称。建议取业务相关的名称，便于区分。消费组可用于实现广播和单播的能力。正常情况下，一条消息只会被一个消费组消费一次，但是可以被多个消费组消费多次。
consumer.auto.offset.reset	可选	earliest	当消费组没有合法的消费记录时，使用此配置对消费进度进行重置。例如：服务侧未找到消费组的消费记录或记录的消费进度已失效。 earliest：重置消费进度到最早的一条消息。 latest：重置消费进度到最新的一条消息。可以用于新的消费组跳过历史数据。
consumer.enable.auto.commit	可选	true	是否开启自动提交消费进度。开启后，无需调用消费进度的提交方法也可将消费进度保存到服务侧。建议生产环境使用关闭自动提交，在确定处理成功后选择合适的时机手动提交消费进度，避免自动提交处理失败的消息。
sasl.mechanism	可选	PLAIN	SASL 认证算法类型，使用 SASL 接入点时必选。 PLAIN：PLAIN 机制。 SCRAM-SHA-256：SCRAM 机制。
sasl.username	可选		SASL 认证的账号名，使用 SASL 接入点时必选。请根据客户端认证机制，填写对应类型用户的用户名及密码进行进行 SASL 认证，例如在 PLAIN 机制下使用 PLAIN 用户的用户名及密码。
sasl.password	可选		SASL 认证的账号密码，使用 SASL 接入点时必选。根据客户端认证机制，填写对应类型用户的用户名及密码进行进行 SASL 认证，例如在 PLAIN 机制下使用 PLAIN 用户的用户名及密码。