117.5. KafkaMirrorMakerConsumerSpec 模式属性

numStreams

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

整数

offsetCommitInterval

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

整数

bootstrapServers

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

字符串

groupId

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

字符串

身份验证

用于连接集群的身份验证配置。这个类型取决于给定对象中的 authentication.type 属性的值，它必须是 [tls, scram-sha-256, scram-sha-256, scram-sha-512, plain, oauth]。

KafkaClientAuthenticationTls, KafkaClientAuthenticationScramSha256, KafkaClientAuthenticationScramSha512, KafkaClientAuthenticationPlain, KafkaClientAuthenticationOAuth

config

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

map

tls

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

ClientTls