0

我正在尝试运行:

./bin/connect-mirror-maker.sh ./config/mirror-maker.properties

我有以下配置:

clusters = A, B
connector.client.config.override.policy = All
A.bootstrap.servers = hostA1:9093, hostA2:9093
B.bootstrap.servers = hostB1:9093, hostB2:9093
A->B.enabled = true
B->A.enabled = false
A->B.topics = mytopic
A->B.rename.topics = false
A->B.replication.factor = 3
A->B.consumer.overrides.auto.offset.reset = latest
A->B.consumer.auto.offset.reset = latest
A->B.source.consumer.auto.offset.reset = latest
A->B.target.consumer.auto.offset.reset = latest
A->B.source.cluster.consumer.overrides.auto.offset.reset = latest
A->B.target.cluster.consumer.overrides.auto.offset.reset = latest
consumer.overrides.auto.offset.reset = latest
consumer.auto.offset.reset = latest
auto.offset.reset = latest

security.protocol=SSL
ssl.keystore.location=/etc/ssl/jsse/kafka.keystore.jks
ssl.truststore.location=/etc/ssl/jsse/kafka.truststore.jks
ssl.endpoint.identification.algorithm=
ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1
ssl.keystore.password=xxx
ssl.key.password=xxx
ssl.truststore.password=xxx

复制工作正常,但我看到消费者不是从最新的偏移量开始,而是从最早的偏移量开始,正如您在配置中看到的那样,我尝试了很多组合,但任何组合都不起作用我想知道如何禁用重命名,因为我想从旧的 kafka-mirror 迁移

4

1 回答 1

1

好的,对于遇到类似问题的每个人,这是已确认的错误,今天已报告/确认:

https://issues.apache.org/jira/browse/KAFKA-10160

于 2020-06-15T14:13:10.280 回答