@Override
            public long timeoutMs() {
                return timeoutMs;
            }
@return the current timeout that should be used for health check REST requests, in milliseconds
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestRequestTimeout.java