Пользовательский соединитель Kafka — тайм-аут при создании конфигурации задачи ⇐ JAVA

[Anonymous]

Я разрабатываю специальный соединитель. Я хотел добавить динамическую горизонтальную масштабируемость. Таким образом, соединитель, объект класса public class CustomConnector расширяет SourceConnector, создает динамическое количество задач, предоставляя правильное количество конфигураций задач в методе public java.util.List TaskConfigs( int maxTasks).
Проблема в том, что вычисление необходимого количества конфигураций задач занимает около 6 минут. В это время инфраструктура kafka-connect считает, что что-то случилось с брокером, которому был назначен соединитель,brokerA, и платформа переназначает соединитель другому брокеру,brokerB. БрокерA завершает задание и создается задач x. ЗатемbrokerB заканчивает вычисления и у меня задач в два раза больше, чем нужно.
Вопрос: есть ли возможность увеличить таймаут во фреймворке, чтобы ждать больше времени для задач?< /strong>
PS. Я знаю, что очевидным решением является повышение производительности вычислений, но это невозможно сделать просто так.

Подробнее здесь: https://stackoverflow.com/questions/791 ... n-creation