Hi All, I am using managed flink on was and trying to read from kafka msk and I am having an issue with this -

<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?

Make sure that you are adding to the build file correctly it should look something like this:

<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>