in src/main/java/org/apache/doris/kafka/connector/utils/BackendUtils.java [46:56]
public String getAvailableBackend() {
long tmp = pos + backends.size();
while (pos < tmp) {
BackendV2.BackendRowV2 backend = backends.get((int) (pos++ % backends.size()));
String res = backend.toBackendString();
if (tryHttpConnection(res)) {
return res;
}
}
throw new DorisException("no available backend.");
}