Hi All, I am using managed flink on was and trying...
# troubleshooting
n
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?
d
Make sure that you are adding to the build file correctly it should look something like this:
Copy code
<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>
Also how are you building your “fat” jar?