joshua2519 opened a new pull request, #21261:
URL: https://github.com/apache/kafka/pull/21261
Migrates `NodeToControllerChannelManager` and related classes from Scala
(core module) to Java (server module).
### New Java Classes (server module)
- `ControllerNodeProvider` - Interface for discovering active controller
- `ControllerInformation` - Controller connection details record
- `RaftControllerNodeProvider` - KRaft implementation finding controller
via Raft metadata
- `NodeToControllerChannelManagerImpl` - Manages node-to-controller
communication channel
- `NodeToControllerRequestThread` - Background thread handling request
queue and retries
- `NodeToControllerQueueItem` - Queued request record with timeout tracking
### Updated
- `AbstractKafkaConfig` - Added
`addReconfigurable()`/`removeReconfigurable()` methods to support migration
- `KafkaConfig` - Added `override` keywords for reconfigurable methods
- Updated imports and usages across core module classes and tests
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
