小编Yog*_*pta的帖子

可以说我有两个Kafka集群，我正在使用镜像制作器将主题从一个集群镜像到另一个集群。我了解消费者有一个嵌入式生产者来向__consumer-offsetKafka集群中的主题提交偏移量。我需要知道如果主要的Kafka群集出现故障会怎样？我们是否也同步__consumer-offset主题？我认为，由于辅助群集可能具有不同数量的代理和其他设置。

请告诉我们Kafka镜像集群如何处理消费者补偿？

是否auto.offset.reset设置在这里发挥作用？

我正在努力访问成员变量,但无法找到任何解释.如果我调用app.initDB(config),它可以工作; 但是当我按原样调用initDB()时,config为null.请查看代码段以找到有问题的行.

我期待配置初始化,因为我在这里调用app对象.

public class App {
    public RestConfig config;

    public App(RestConfig config) {
        config = config;
    }

    public void initDB() { // miss type returns
        System.out.println(config); // <-- prints null , why?**
    }
}

class RestMain {
    public static void main(String[] args) throws IOException {
        RestConfig config = new RestConfig();
        App app = new App(config);
        app.initDB();
    }

}

public class RestConfig {
    //some config...
}