Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Not compatible with Kafka 3.8 libraries #781

Open
dpiddock opened this issue Sep 3, 2024 · 0 comments
Open

Not compatible with Kafka 3.8 libraries #781

dpiddock opened this issue Sep 3, 2024 · 0 comments

Comments

@dpiddock
Copy link

dpiddock commented Sep 3, 2024

We tried upgrading our client libraries to Kafka 3.8 and started to get an exception:

Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:233)
java.lang.NoClassDefFoundError: Could not initialize class io.confluent.connect.s3.S3SinkConnectorConfig$CannedAclValidator
	at io.confluent.connect.s3.S3SinkConnectorConfig.newConfigDef(S3SinkConnectorConfig.java:467)
	at io.confluent.connect.s3.S3SinkConnectorConfig.<init>(S3SinkConnectorConfig.java:839)
	at io.confluent.connect.s3.S3SinkTask.start(S3SinkTask.java:100)
	at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:323)
	at org.apache.kafka.connect.runtime.WorkerTask.doStart(WorkerTask.java:175)
	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:224)
	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:280)
	at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:840)
Caused by: java.lang.ExceptionInInitializerError: Exception java.lang.NoSuchMethodError: 'java.lang.String org.apache.kafka.common.utils.Utils.join(java.util.Collection, java.lang.String)' [in thread "task-thread-backup-events-to-s3-113"]
	at io.confluent.connect.s3.S3SinkConnectorConfig$CannedAclValidator.<clinit>(S3SinkConnectorConfig.java:1222)
	... 13 more

Kafka common.utils.Utils since 3.8.0 has removed the join method and replaced all uses with String.join() in apache/kafka#15823

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant