You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Blanchard Matthieu (JIRA)" <ji...@apache.org> on 2019/02/07 11:49:00 UTC
[jira] [Created] (KAFKA-7907) KafkaDistributed
Blanchard Matthieu created KAFKA-7907:
-----------------------------------------
Summary: KafkaDistributed
Key: KAFKA-7907
URL: https://issues.apache.org/jira/browse/KAFKA-7907
Project: Kafka
Issue Type: Bug
Components: KafkaConnect
Affects Versions: 2.1.0
Reporter: Blanchard Matthieu
I try today to upgrade my kafka confluent from 5.0.0 to 5.1.0.
It use now kafka 2.1.0.
When I try to create my connectors (dbz sql connector), when it worked in 2.0.0, I've got now this error :
{code:java}
org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler
at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:178)
at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:104)
at org.apache.kafka.connect.runtime.WorkerSourceTask.convertTransformedRecord(WorkerSourceTask.java:269)
at org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:293)
at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:228)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.avro.AvroRuntimeException: Unknown datum class: class java.lang.Short
at org.apache.avro.util.internal.JacksonUtils.toJson(JacksonUtils.java:87)
at org.apache.avro.util.internal.JacksonUtils.toJsonNode(JacksonUtils.java:48)
at org.apache.avro.Schema$Field.<init>(Schema.java:423)
at org.apache.avro.Schema$Field.<init>(Schema.java:415)
at io.confluent.connect.avro.AvroData.addAvroRecordField(AvroData.java:964)
at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:847)
at io.confluent.connect.avro.AvroData.fromConnectSchemaWithCycle(AvroData.java:942)
at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:834)
at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:689)
at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:683)
at io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:328)
at io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:76)
at org.apache.kafka.connect.runtime.WorkerSourceTask.lambda$convertTransformedRecord$2(WorkerSourceTask.java:269)
at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:128)
at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:162)
... 11 more
[2019-02-07 12:39:46,301] ERROR WorkerSourceTask\{id=resa2ToKafka-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:178)
{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
Re: [jira] [Created] (KAFKA-7907) KafkaDistributed
Posted by Randall Hauch <rh...@gmail.com>.
This is a regression in Confluent's AvroConverter that shipped in Confluent
Platform 5.1.0; earlier versions were not affected. Please see
https://github.com/confluentinc/schema-registry/issues/968 for more
details. It has already been fixed, and will be in the upcoming Confluent
Platform 5.1.1 release as well as the next 5.2.0 release.
Best regards,
Randall
On Thu, Feb 7, 2019 at 5:49 AM Blanchard Matthieu (JIRA) <ji...@apache.org>
wrote:
> Blanchard Matthieu created KAFKA-7907:
> -----------------------------------------
>
> Summary: KafkaDistributed
> Key: KAFKA-7907
> URL: https://issues.apache.org/jira/browse/KAFKA-7907
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 2.1.0
> Reporter: Blanchard Matthieu
>
>
> I try today to upgrade my kafka confluent from 5.0.0 to 5.1.0.
>
> It use now kafka 2.1.0.
>
> When I try to create my connectors (dbz sql connector), when it worked in
> 2.0.0, I've got now this error :
>
> {code:java}
>
>
> org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in
> error handler
> at
> org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:178)
> at
> org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:104)
> at
> org.apache.kafka.connect.runtime.WorkerSourceTask.convertTransformedRecord(WorkerSourceTask.java:269)
> at
> org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:293)
> at
> org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:228)
> at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175)
> at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: org.apache.avro.AvroRuntimeException: Unknown datum class:
> class java.lang.Short
> at org.apache.avro.util.internal.JacksonUtils.toJson(JacksonUtils.java:87)
> at
> org.apache.avro.util.internal.JacksonUtils.toJsonNode(JacksonUtils.java:48)
> at org.apache.avro.Schema$Field.<init>(Schema.java:423)
> at org.apache.avro.Schema$Field.<init>(Schema.java:415)
> at
> io.confluent.connect.avro.AvroData.addAvroRecordField(AvroData.java:964)
> at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:847)
> at
> io.confluent.connect.avro.AvroData.fromConnectSchemaWithCycle(AvroData.java:942)
> at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:834)
> at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:689)
> at io.confluent.connect.avro.AvroData.fromConnectSchema(AvroData.java:683)
> at io.confluent.connect.avro.AvroData.fromConnectData(AvroData.java:328)
> at
> io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:76)
> at
> org.apache.kafka.connect.runtime.WorkerSourceTask.lambda$convertTransformedRecord$2(WorkerSourceTask.java:269)
> at
> org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:128)
> at
> org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:162)
> ... 11 more
> [2019-02-07 12:39:46,301] ERROR WorkerSourceTask\{id=resa2ToKafka-0} Task
> is being killed and will not recover until manually restarted
> (org.apache.kafka.connect.runtime.WorkerTask:178)
>
>
>
> {code}
>
>
>
> --
> This message was sent by Atlassian JIRA
> (v7.6.3#76005)
>