120.5. KafkaMirrorMakerConsumerSpec 模式属性

numStreams

整数

指定要创建的消费者流线程数量。

offsetCommitInterval

整数

以 ms 为单位指定偏移 auto-commit 间隔。默认值为 60000。

bootstrapServers

string

用于建立到 Kafka 集群的初始连接的 host:port 对列表。

groupId

string

标识此消费者所属的消费者组的唯一字符串。

身份验证

KafkaClientAuthenticationTls, KafkaClientAuthenticationScramSha256, KafkaClientAuthenticationScramSha512, KafkaClientAuthenticationPlain, KafkaClientAuthenticationOAuth

用于连接集群的身份验证配置。

config

map

MirrorMaker 消费者配置。无法设置带有以下前缀的属性：ssl., bootstrap.servers, group.id, sasl., security., interceptor.classes （除 ssl.endpoint.identification.algorithm, ssl.cipher.suites, ssl.protocol, ssl.enabled.protocols）。

tls

clientTLS

将 MirrorMaker 连接到集群的 TLS 配置。