Nishtha Bhattacharjee
08/01/2024, 11:34 PM<http://org.apache.flink.kafka.shaded.org|org.apache.flink.kafka.shaded.org>.apache.commonconfig,ConfigException: Invalid value software
.amazon.msk.auth.iam.IAMClientCallbackHandler for configuration sasl.client.callback.handler.class: Class software.amazon.msk.auth.iam.IAMClientCallbackHandler could not be found
I am using this config in my connector sasl.client.callback.handler.class = software.amazon.msk.auth.iam.IAMClientCallbackHandler
I have packaged my jar(s) into a uber jar, I think I ll have to add this to the classpath differently on managed flink. Any ideas?D. Draco O'Brien
08/03/2024, 6:09 AM<dependencies>
<!-- AWS SDK for Java -->
<dependency>
<groupId>software.amazon.awssdk</groupId>
<artifactId>bom</artifactId>
<version>2.x.x</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- AWS MSK Kafka Client -->
<dependency>
<groupId>software.amazon.msk</groupId>
<artifactId>amazon-msk-connector-kafka-client</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies>
D. Draco O'Brien
08/03/2024, 6:10 AM