jsancio commented on code in PR #15986:
URL: https://github.com/apache/kafka/pull/15986#discussion_r1611939749
##########
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##########
@@ -393,17 +422,35 @@ public void initialize(
logger.info("Reading KRaft snapshot and log as part of the
initialization");
partitionState.updateState();
- VoterSet lastVoterSet = partitionState.lastVoterSet();
- requestManager = new RequestManager(
- lastVoterSet.voterIds(),
- quorumConfig.retryBackoffMs(),
- quorumConfig.requestTimeoutMs(),
- random
- );
+ if (requestManager == null) {
+ // The request manager wasn't created using the bootstrap servers
+ // create it using the voters static configuration
+ List<Node> bootstrapNodes = voterAddresses
+ .entrySet()
+ .stream()
+ .map(entry ->
+ new Node(
+ entry.getKey(),
+ entry.getValue().getHostString(),
+ entry.getValue().getPort()
+ )
+ )
+ .collect(Collectors.toList());
+
+ logger.info("Starting request manager with bootstrap servers: {}",
bootstrapNodes);
Review Comment:
Done.
--
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.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
