Кафка: Почему метод start () Sink Connector вызывается дважды? - PullRequest
Новая
       11

Кафка: Почему метод start () Sink Connector вызывается дважды?

0 голосов
/ 26 сентября 2018

Я запускаю работника в распределенном режиме и использую REST API для запуска ОДНОГО соединителя. У меня есть оператор печати в start () класса HdfsSinkConnector: 

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

}

Я вижу, что этот метод вызывается дважды для одного и того же соединителя, и это вызовет проблемы, потому что мне нужно включить пользовательские инициализации в этот метод start (), и я бы не хотел, чтобы они были инициализированы дважды.

1) Когда вызывается метод start ()?

2) Почему он вызывается ДВАЖДЫ, хотя я запускаю только один разъем и проверил, что не работает другой разъемв том же рабочем сервисе?

3) Как убедиться, что этот метод start () вызывается только один раз для каждого соединителя?

...