mattcasters opened a new pull request, #7524: URL: https://github.com/apache/hop/pull/7524
## Summary - Adds **Stop when idle** (`stopWhenIdle`) and **Max idle time (ms)** (`maxIdleTimeMs`, default 500) to the Kafka Consumer transform. - When enabled, the consumer polls with a 100 ms timeout and stops gracefully after no records are received for the configured idle period (batch-style “drain the topic” use cases). - Continuous streaming behavior is unchanged when the option is off. - Unit tests, Kafka integration test (`main-0003-kafka-test-stop-when-idle`), user-manual Batch tab docs, and Kafka IT bootstrap defaults for the single-JVM runner. Fixes #7519 ## Test plan - [x] `./mvnw -pl plugins/transforms/kafka -am test -Dtest=KafkaConsumerInputMetaTest -Dsurefire.failIfNoSpecifiedTests=false` - [x] `./integration-tests/scripts/run-tests-docker.sh PROJECT_NAME=kafka KEEP_IMAGES=true CLIENT_UNZIP=true` — all 4 kafka tests passed, including idle timeout graceful stop - [ ] Spotless/CI on PR -- 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]
