davsclaus opened a new pull request, #25156:
URL: https://github.com/apache/camel/pull/25156

   ## Summary
   
   - Switch Kafka consumer reconnection from `ForegroundTask` to 
`BackgroundTask` so the task stays registered in the internal task registry for 
the full reconnection duration, making it visible via TUI Internal Tasks tab 
and `camel get internal-task` CLI
   - Combine the two sequential tasks (create + subscribe) into a single 
`reconnectTask()` using a per-consumer `ScheduledExecutorService` (same pattern 
as camel-sjms)
   - Fix `IllegalMonitorStateException` in `SingleNodeKafkaResumeStrategyTest` 
where a releaser thread tried to unlock a `ReentrantLock` owned by another 
thread
   
   ## Test plan
   
   - [x] All 194 existing camel-kafka unit tests pass
   - [x] `SingleNodeKafkaResumeStrategyTest` no longer produces 
`IllegalMonitorStateException`
   - [ ] Manual: run a Kafka route, stop the broker, verify the reconnect task 
appears in `camel get internal-task` and TUI Internal Tasks tab
   
   _Claude Code on behalf of davsclaus_
   
   🤖 Generated with [Claude Code](https://claude.com/claude-code)


-- 
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]

Reply via email to