Activity
Add min.insync.replicas config for sample store and maintanence topics
Add min.insync.replicas config for sample store and maintanence topics
Force push
Add min.insync.replicas config for sample store and maintanence topics
Add min.insync.replicas config for sample store and maintanence topics
Force push
Add min.insync.replicas config for sample store and maintanence topics
Add min.insync.replicas config for sample store and maintanence topics
Force push
Add min.insync.replicas config for sample store and maintanence topics
Add min.insync.replicas config for sample store and maintanence topics
Add min.insync.replicas config for sample store and maintanence topics
Add min.insync.replicas config for sample store and maintanence topics
Force push
Add min.insync.replicas config for sample store and maintanence topics
Add min.insync.replicas config for sample store and maintanence topics
Force push
Add min.insync.replicas config for sample store and maintanence topics
Add min.insync.replicas config for sample store and maintanence topics
Addressing feedback - merging caught exceptions
Addressing feedback - merging caught exceptions
Refactoring to address comments
Refactoring to address comments
Use reflection to use correct LogConfig fields/methods
Use reflection to use correct LogConfig fields/methods
Force push
Use reflection to use correct LogConfig fields/methods
Use reflection to use correct LogConfig fields/methods
Force push
Use reflection to use correct LogConfig fields/methods
Use reflection to use correct LogConfig fields/methods
Force push
Use reflection to use correct LogConfig fields/methods
Use reflection to use correct LogConfig fields/methods
Future-proof against Kafka 3.5 breaking changes
Future-proof against Kafka 3.5 breaking changes
Pass concurrency manager to getLeadershipMovementTasks()
Pass concurrency manager to getLeadershipMovementTasks()
Force push
Pass concurrency manager to getLeadershipMovementTasks()
Pass concurrency manager to getLeadershipMovementTasks()
Force push
Pass concurrency manager to getLeadershipMovementTasks()
Pass concurrency manager to getLeadershipMovementTasks()
Initialize leadershipConcurrency for scaled brokers to avoid NPE
Initialize leadershipConcurrency for scaled brokers to avoid NPE