-
Notifications
You must be signed in to change notification settings - Fork 196
Open
Description
I am deploying a confluent stack in Kubernetes which install the Apache Iceberg Connector like this:
apiVersion: platform.confluent.io/v1beta1
kind: Connect
metadata:
name: connect
namespace: confluent
spec:
replicas: 1
image:
application: confluentinc/cp-server-connect:7.9.0
init: confluentinc/confluent-init-container:2.11.0
build:
type: onDemand
onDemand:
plugins:
confluentHub:
- name: debezium-connector-mysql
owner: debezium
version: latest
- name: iceberg-kafka-connect
owner: iceberg
version: latest
But as soon as I create a sink connector, I have this error trace:
{
"name":"sink-lara-documents",
"connector":{
"state":"FAILED",
"worker_id":"connect-0.connect.confluent.svc.cluster.local:8083",
"trace":"java.lang.NoClassDefFoundError: org/apache/iceberg/IcebergBuild\n\tat org.apache.iceberg.connect.IcebergSinkConfig.version(IcebergSinkConfig.java:109)\n\tat org.apache.iceberg.connect.IcebergSinkConnector.version(IcebergSinkConnector.java:37)\n\tat org.apache.kafka.connect.runtime.WorkerConnector$ConnectorMetricsGroup.<init>(WorkerConnector.java:502)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.<init>(WorkerConnector.java:103)\n\tat org.apache.kafka.connect.runtime.Worker.startConnector(Worker.java:412)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.startConnector(DistributedHerder.java:2194)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$restartConnector$29(DistributedHerder.java:1518)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.runRequest(DistributedHerder.java:2471)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:502)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:387)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)\n\tat java.base/java.util.concurrent.FutureTask.run(Unknown Source)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)\n\tat java.base/java.lang.Thread.run(Unknown Source)\nCaused by: java.lang.ClassNotFoundException: org.apache.iceberg.IcebergBuild\n\t... 15 more\n"
},
"tasks":[
],
"type":"sink"
}
Metadata
Metadata
Assignees
Labels
No labels