jakubmalek commented on issue #1662: URL: https://github.com/apache/camel-kafka-connector/issues/1662#issuecomment-2284032554
OK I think I know how this can be implemented now. 1. The checkpoint configuration could be provided as this `#class:org.apache.camel.kafkaconnector.azureeventhubssource.checkpoint.EventHubOffsetCheckpointStore` string so it's initialized by Camel 2. The `EventHubOffsetCheckpointStore` would implement `CamelContextAware` interface, so it can access `CamelContext` 3. The `CamelSourceTask` would bind a bean providing access to `SourceTaskContext` and option to configure provider of the source partition and source offset from the `Exchange` I still need some time to put it all together, but I think I got the rough idea how it can be setup without need for modification of the generated 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: commits-unsubscr...@camel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
