Остановить коннектор кафки

В реализации kafka connect SinkTask, если возникает неизбежное исключение, если я вызываю метод stop() из своего кода, коннектор полностью останавливается?


person Arun Shankar    schedule 20.06.2018    source источник


Ответы (1)


Только та задача, которая столкнулась с исключением, остановится

Кластер подключения может иметь несколько коннекторов, которые не будут останавливаться, и могут быть другие задачи для одного подключения в зависимости от ваших конфигураций, которым, например, будут назначены разные, чистые данные, которые можно обрабатывать.

person OneCricketeer    schedule 21.06.2018