There is an interceptorClasses parameter in the Camel Kafka configuration. https://camel.apache.org/components/4.4.x/kafka-component.html#_component_option_interceptorClasses
Il giorno ven 30 ago 2024 alle ore 15:07 Pagano, Marco <marco.pag...@accenture.com.invalid> ha scritto: > In order to configure an additional interceptor for consumers from initial > deployment in the source cluster an interceptor must be configured to allow > consumers to resume when reading topics that are replicated to the > secondary cluster. > > Confluent support (we use Confluent provider for Kafka) suggest us to: > configure this property: > `interceptor.classes=io.confluent.connect.replicator.offsets.ConsumerTimestampsInterceptor` > add this dependency in the maven project: ` <dependency> > <groupId>io.confluent</groupId> > <artifactId>timestamp-interceptor</artifactId> <version>7.6.1</version> > </dependency>` > > Ok for the dependency, but how can configure the property in camel? > Best regards. > > Marco Pagano > Accenture Technology > BSS Factory - Italy Delivery Center. > * E-mail : marco.pag...@accenture.com<mailto: > marco.pag...@accenture.com> > > > ________________________________ > > This message is for the designated recipient only and may contain > privileged, proprietary, or otherwise confidential information. If you have > received it in error, please notify the sender immediately and delete the > original. Any other use of the e-mail by you is prohibited. Where allowed > by local law, electronic communications with Accenture and its affiliates, > including e-mail and instant messaging (including content), may be scanned > by our systems for the purposes of information security, AI-powered support > capabilities, and assessment of internal compliance with Accenture policy. > Your privacy is important to us. Accenture uses your personal data only in > compliance with data protection laws. For further information on how > Accenture processes your personal data, please see our privacy statement at > https://www.accenture.com/us-en/privacy-policy. > > ______________________________________________________________________________________ > > www.accenture.com >
