Re: [I] Azure EventHubs offset checkpoint store [camel-kafka-connector]

2024-08-12 Thread via GitHub
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.azureeven

Re: [I] Azure EventHubs offset checkpoint store [camel-kafka-connector]

2024-08-09 Thread via GitHub
jakubmalek commented on issue #1662: URL: https://github.com/apache/camel-kafka-connector/issues/1662#issuecomment-2278099954 The problem is that `CheckpointStore` requires `OffsetStoreReader` that can be obtained only during task startup. As I understand I can define a bean with somethi

Re: [I] Azure EventHubs offset checkpoint store [camel-kafka-connector]

2024-08-09 Thread via GitHub
oscerd commented on issue #1662: URL: https://github.com/apache/camel-kafka-connector/issues/1662#issuecomment-2277934359 If you override the source task it will be override once we Regen the connector from the kamelets released catalog. My suggestion would be to mark the parameters as opt

Re: [I] Azure EventHubs offset checkpoint store [camel-kafka-connector]

2024-08-09 Thread via GitHub
jakubmalek commented on issue #1662: URL: https://github.com/apache/camel-kafka-connector/issues/1662#issuecomment-2277923413 To get the rough understanding what I have in mind when it comes to Option A, you check this [commit](https://github.com/apache/camel-kafka-connector/commit/4b5bfaa

[I] Azure EventHubs offset checkpoint store [camel-kafka-connector]

2024-08-09 Thread via GitHub
jakubmalek opened a new issue, #1662: URL: https://github.com/apache/camel-kafka-connector/issues/1662 The [camel-azure-eventhubs-source-kafka-connector](https://camel.apache.org/camel-kafka-connector/4.0.x/reference/connectors/camel-azure-eventhubs-source-kafka-source-connector.html) curre