peterxcli opened a new pull request, #18337: URL: https://github.com/apache/kafka/pull/18337
Enable controller to restart with the same port in ClusterTest. ## Tests In the newly added test `testKRaftIsolatedControllerRestart`, if we don't have the corresponding changes in `PreboundSocketFactoryManager` then the admin will keep retrying connect to the restarted controller, cause the controller's port has changed. ``` [2024-12-28 06:01:46,521] INFO [broker-0-to-controller-forwarding-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:43227 (id: 3000 rack: null isFenced: false) (kafka.server.NodeToControllerRequestThread:66) [2024-12-28 06:01:46,546] INFO [RaftManager id=0] Node 3000 disconnected. (org.apache.kafka.clients.NetworkClient:1073) [2024-12-28 06:01:46,546] WARN [RaftManager id=0] Connection to node 3000 (localhost/127.0.0.1:43227) could not be established. Node may not be available. (org.apache.kafka.clients.NetworkClient:899) [2024-12-28 06:01:46,547] INFO [controller-3000-to-controller-registration-channel-manager]: Recorded new KRaft controller, from now on will use node localhost:43227 (id: 3000 rack: null isFenced: false) (kafka.server.NodeToControllerRequestThread:66) [2024-12-28 06:01:46,548] INFO [NodeToControllerChannelManager id=3000 name=registration] Node 3000 disconnected. (org.apache.kafka.clients.NetworkClient:1073) ... // repeated same log messages ``` -- 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
