We are looking for a implementation to send invalidating cache(with content path info) info to external system .. Is there any advantage of using one of the above implementation over the other ? Or when would you prefer one over the other ?  

Hello @Vijayalakshmi_S I tried following the above steps ..but i still get the ClassNotFoundException.  I added the required class package i needed in here  <Import-Package>    org.apache.kafka.common.security.plain,</Import-Package><Export-Package>    org.apache.kafka.common.security.plain.*;versio...

@Jörg_Hoh So does that mean we wouldnt be able to make the above implementation work in AEM ?

I did take a look at it @Jörg_Hoh . The only diff with my implementation is i am trying to connect to secure kafka using these props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SASL_SSL");props.put(SaslConfigs.SASL_MECHANISM, "PLAIN");props.put(SaslConfigs.SASL_JAAS_CONFIG, "org.apache.kafka....

@Nitin_laad I tried to follow the above the link . I tried to added this org.apache.kafka.common.security in the Export package section in the pom file . And it blew up my complete local instance . I see this when i tried to restart my local instance .java.lang.StackOverflowError at java.security.A...

I am trying to connect to kafka using props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SASL_SSL");props.put(SaslConfigs.SASL_MECHANISM, "PLAIN");props.put(SaslConfigs.SASL_JAAS_CONFIG, "org.apache.kafka.common.security.plain.PlainLoginModule required   username=‘x’  password=‘x’;”); When i a...

@Jörg_Hoh Is there a code snippet for this kind of implementation that i can take a look at?

@Jörg_Hoh I would need a client-side certificate for authorization.

But how would i setup the authentication part in this case ?

I would like to use the replicating mechanism