kafka:为什么sink connector start()方法被调用了两次?

dtcbnfnu  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(161)

我在分布式模式下启动worker并使用rest api启动一个连接器,在hdfssinkconnector类的start()中有一个print语句:

@Override
 public void start(Map<String, String> props) throws ConnectException {
     System.out.println("In connector start method()");

}
我看到这个方法被同一个连接器调用了两次,这会导致问题,因为我需要在这个start()方法中包含自定义初始化,我不希望它们被初始化两次。
1) start()方法何时调用?
2) 尽管我只启动了一个连接器,并且检查了同一个辅助服务中没有运行其他连接器,但为什么它会被调用两次?
3) 如何确保每个连接器只调用一次start()方法?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题