-
Notifications
You must be signed in to change notification settings - Fork 436
Open
Description
Hi! After updating from version 15.0.0
to version 15.0.1
we encounter the following issue:
ERROR org.apache.kafka.connect.runtime.WorkerTask - WorkerSinkTask{id=foo-bar-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted.
org.apache.kafka.common.config.ConfigException: Missing required configuration "taskId" which has no default value.
at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:534) ~[kafka-clients-8.0.0-ccs.jar:?]
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:524) ~[kafka-clients-8.0.0-ccs.jar:?]
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:115) ~[kafka-clients-8.0.0-ccs.jar:?]
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:133) ~[kafka-clients-8.0.0-ccs.jar:?]
at io.confluent.connect.elasticsearch.ElasticsearchSinkConnectorConfig.<init>(ElasticsearchSinkConnectorConfig.java:964) ~[kafka-connect-elasticsearch-15.0.1.jar:?]
at io.confluent.connect.elasticsearch.ElasticsearchSinkTaskConfig.<init>(ElasticsearchSinkTaskConfig.java:49) ~[kafka-connect-elasticsearch-15.0.1.jar:?]
at io.confluent.connect.elasticsearch.ElasticsearchSinkTask.start(ElasticsearchSinkTask.java:63) ~[kafka-connect-elasticsearch-15.0.1.jar:?]
at io.confluent.connect.elasticsearch.ElasticsearchSinkTask.start(ElasticsearchSinkTask.java:56) ~[kafka-connect-elasticsearch-15.0.1.jar:?]
at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:324) ~[connect-runtime-8.0.0-ccs.jar:?]
at org.apache.kafka.connect.runtime.WorkerTask.doStart(WorkerTask.java:176) ~[connect-runtime-8.0.0-ccs.jar:?]
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:225) ~[connect-runtime-8.0.0-ccs.jar:?]
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:281) ~[connect-runtime-8.0.0-ccs.jar:?]
at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:238) ~[connect-runtime-8.0.0-ccs.jar:?]
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572) ~[?:?]
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317) ~[?:?]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
at java.base/java.lang.Thread.run(Thread.java:1583) [?:?]
I am looking for suggestions as to how to fix this. Any help would be appreciated. Thank you!
boris-dhl and lderks
Metadata
Metadata
Assignees
Labels
No labels