Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Kafka connect issue

Kafka connect issue

New Contributor

curl -GET kconnect:8083/connectors/mynewconnector/status/
{"name":"mynewconnector","connector":{"state":"RUNNING","worker_id":"0.0.0.0:8083"},"tasks":[{"id":0,"state":"FAILED","worker_id":"0.0.0.0:8083","trace":"org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:178)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:104)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.convertTransformedRecord(WorkerSourceTask.java:287)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:316)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:240)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tat java.base/java.lang.Thread.run(Thread.java:834)\nCaused by: java.lang.ClassCastException: class org.glassfish.jersey.jaxb.internal.JaxbAutoDiscoverable cannot be cast to class org.glassfish.jersey.internal.spi.AutoDiscoverable (org.glassfish.jersey.jaxb.internal.JaxbAutoDiscoverable is in unnamed module of loader 'app'; org.glassfish.jersey.internal.spi.AutoDiscoverable is in unnamed module of loader org.apache.kafka.connect.runtime.isolation.PluginClassLoader @1757cd72)\n\tat org.glassfish.jersey.model.internal.CommonConfig$2.compare(CommonConfig.java:592)\n\tat java.base/java.util.TreeMap.compare(TreeMap.java:1292)\n\tat java.base/java.util.TreeMap.put(TreeMap.java:536)\n\tat java.base/java.util.TreeSet.add(TreeSet.java:255)\n\tat java.base/java.util.AbstractCollection.addAll(AbstractCollection.java:352)\n\tat java.base/java.util.TreeSet.addAll(TreeSet.java:312)\n\tat org.glassfish.jersey.model.internal.CommonConfig.configureAutoDiscoverableProviders(CommonConfig.java:610)\n\tat org.glassfish.jersey.client.ClientConfig$State.configureAutoDiscoverableProviders(ClientConfig.java:364)\n\tat org.glassfish.jersey.client.ClientConfig$State.initRuntime(ClientConfig.java:399)\n\tat org.glassfish.jersey.client.ClientConfig$State.access$000(ClientConfig.java:90)\n\tat org.glassfish.jersey.client.ClientConfig$State$3.get(ClientConfig.java:122)\n\tat org.glassfish.jersey.client.ClientConfig$State$3.get(ClientConfig.java:119)\n\tat org.glassfish.jersey.internal.util.collection.Values$LazyValueImpl.get(Values.java:340)\n\tat org.glassfish.jersey.client.ClientConfig.getRuntime(ClientConfig.java:733)\n\tat org.glassfish.jersey.client.ClientRequest.getConfiguration(ClientRequest.java:285)\n\tat org.glassfish.jersey.client.JerseyInvocation.validateHttpMethodAndEntity(JerseyInvocation.java:135)\n\tat org.glassfish.jersey.client.JerseyInvocation.<init>(JerseyInvocation.java:105)\n\tat org.glassfish.jersey.client.JerseyInvocation.<init>(JerseyInvocation.java:101)\n\tat org.glassfish.jersey.client.JerseyInvocation.<init>(JerseyInvocation.java:92)\n\tat org.glassfish.jersey.client.JerseyInvocation$Builder.method(JerseyInvocation.java:448)\n\tat org.glassfish.jersey.client.JerseyInvocation$Builder.post(JerseyInvocation.java:349)\n\tat com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient$15.run(SchemaRegistryClient.java:1079)\n\tat com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient$15.run(SchemaRegistryClient.java:1076)\n\tat java.base/java.security.AccessController.doPrivileged(Native Method)\n\tat java.base/javax.security.auth.Subject.doAs(Subject.java:361)\n\tat com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient.postEntity(SchemaRegistryClient.java:1076)\n\tat com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient.doRegisterSchemaMetadata(SchemaRegistryClient.java:415)\n\tat com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient.addSchemaMetadata(SchemaRegistryClient.java:398)\n\tat com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient.registerSchemaMetadata(SchemaRegistryClient.java:390)\n\tat com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient.addSchemaVersion(SchemaRegistryClient.java:443)\n\tat com.hortonworks.registries.schemaregistry.client.SchemaRegistryClient.addSchemaVersion(SchemaRegistryClient.java:431)\n\tat com.hortonworks.registries.schemaregistry.serde.AbstractSnapshotSerializer.serialize(AbstractSnapshotSerializer.java:64)\n\tat com.hortonworks.registries.schemaregistry.serdes.avro.kafka.KafkaAvroSerializer.serialize(KafkaAvroSerializer.java:86)\n\tat com.swissport.kafka.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:59)\n\tat org.apache.kafka.connect.storage.Converter.fromConnectData(Converter.java:62)\n\tat org.apache.kafka.connect.runtime.WorkerSourceTask.lambda$convertTransformedRecord$1(WorkerSourceTask.java:287)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:128)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:162)\n\t... 11 more\n"}

Don't have an account?
Coming from Hortonworks? Activate your account here