Мой исходный соединитель выбрасывает Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Error while forwarding register schema request to the master; error code: 50003
или Caused by: io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException: Master not known
Я обнаружил, что это произошло, когда изменяется мастер реестра схемы, и у меня есть две реплики реестра-схемы под одной и той же службой на K8S.
Верхнее исключение: org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler
Как увеличить допуск, чтобы соединитель мог повторять попытки еще раз, пока не будет выбран новый мастер?