B.116.4. groupId
使用 consumer.groupId
属性为使用者配置使用者组标识符。
Kafka MirrorMaker 使用 Kafka 使用者来消耗消息,与任何其他 Kafka 消费者客户端一样。从源 Kafka 集群使用的消息会镜像到目标 Kafka 集群。需要组标识符,因为使用者需要成为分配分区的消费者组的一部分。
属性 | 描述 |
---|---|
numStreams | 指定要创建的消费者流线程数量。 |
整数 | |
offsetCommitInterval | 以 ms 为单位指定偏移自动提交间隔。默认值为 60000。 |
整数 | |
groupId | 个唯一字符串,用于标识该消费者所属的消费者组。 |
字符串 | |
bootstrapServers | 用于建立与 Kafka 集群的初始连接的 host:port 对列表。 |
字符串 | |
身份验证 |
用于连接到集群的身份验证配置。这个类型取决于给定对象中的 |
| |
config | MirrorMaker 消费者配置.无法设置带有以下前缀的属性: ssl.、bootstrap.servers、group.id、sasl.、security.、拦截器.classes(ssl.endpoint.identification.algorithm、ssl.cipher.suites、ssl.protocol、ssl.enabled.protocols 除外)。 |
map | |
tls | 将 MirrorMaker 连接到集群的 TLS 配置。 |