davsclaus opened a new pull request, #24191: URL: https://github.com/apache/camel/pull/24191
## Summary - Add optional `topicHeaderName` parameter to `TimestampRouter` bean, allowing callers to specify which header contains the topic name instead of always using `KafkaConstants.TOPIC` (`CamelKafkaTopic`) - Add `TimestampRouterTest` with 6 unit tests covering default, custom, empty, null, missing topic, and missing timestamp scenarios ## Context CAMEL-23584 renamed Kafka header constants from `kafka.*` to `CamelKafka*` (e.g. `kafka.TOPIC` → `CamelKafkaTopic`). This broke the `timestamp-router-action` kamelet when used behind a webhook source, because Camel's HTTP components filter `Camel*`-prefixed headers from incoming requests. The `topicHeaderName` option lets the kamelet specify `kafka.TOPIC` as the header to read from, working around the filter. ## Test plan - [x] `TimestampRouterTest` — 6 unit tests all passing - [x] `KafkaIT.kafka()[3]` integration test in `camel-kamelets` passes with the corresponding kamelet change 🤖 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]
