Hi, I’m trying to run flink in a docker container and then use curl to access the rest api and seeing this error

from the jobmanager: 
:29:59.172 [kafka-admin-client-thread | flink.sqlclient-enumerator-admin-client] ERROR org.apache.kafka.common.utils.KafkaThread - Uncaught exception in thread 'kafka-admin-client-thread | flink.sqlclient-enumerator-admin-client':
java.lang.NoClassDefFoundError: Could not initialize class org.apache.kafka.common.message.ApiMessageType
	at org.apache.kafka.common.protocol.ApiKeys.requestHeaderVersion(ApiKeys.java:341) ~[?:?]
	at org.apache.kafka.clients.ClientRequest.makeHeader(ClientRequest.java:93) ~[?:?]
...
	at org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1196) ~[?:?]
	at java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: java.lang.ClassNotFoundException: org.apache.kafka.common.message.AlterReplicaLogDirsRequestData$AlterReplicaLogDir

I’m using this api: https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/ops/rest_api/#jars-jarid-run When I run the same job by logging into the container and executing it manually it runs ok. I’m trying to understand why running it manually works ok but running it via the REST api does not.