rhauch commented on a change in pull request #8536:
URL: https://github.com/apache/kafka/pull/8536#discussion_r414006134
##########
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java
##########
@@ -341,7 +341,15 @@ private void checkAndPutConnectorConfigName(String
connectorName, Map<String, St
// this gives two total hops to resolve the request before
giving up.
boolean recursiveForward = forward == null;
RequestTargetException targetException =
(RequestTargetException) cause;
- String forwardUrl =
UriBuilder.fromUri(targetException.forwardUrl())
+ String forwardedUrl = targetException.forwardUrl();
+ if (forwardedUrl == null) {
+ // the target didn't know of the leader at this moment.
+ // we don't, it probably means that a rebalance has
taken place.
Review comment:
Ack.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
