I am using Ignite Kafka connector with below config:
*connect-standalone.properties*
key.converter.schemas.enable=false
value.converter.schemas.enable=false
key.converter=org.apache.kafka.connect.converters.ByteArrayConverter
value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
*connect-source.properties*
name=quickstart-source
tasks.max=1
connector.class=org.gridgain.kafka.source.IgniteSourceConnector
igniteCfg=/opt/ngs/ashishb/packages/gridgain-enterprise-8.7.6/config/ignite-server-source.xml
topicPrefix=tp
isSchemaless=true
*Cache config*
CREATE TABLE IF NOT EXISTS Person5 (id int, cityId int, name varchar,
PRIMARY KEY (id, cityId)) WITH
"template=partitioned,backups=1,affinity_key=cityId, key_type=Person1Key,
value_type=Person1, cache_name=person5";
INSERT INTO Person5 (id, name, cityid) VALUES (1, 'Ashish Bhosle', 8);
As soon as I insert the record I got below exception:
[2019-12-17 11:42:27,342] ERROR
WorkerSourceTask{id=gridgain-quickstart-source-0} Task threw an uncaught and
unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:179)
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:267)
at
org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:294)
at
org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:229)
at
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
at
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
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.kafka.connect.errors.DataException: ByteArrayConverter
is not compatible with objects of type class
org.apache.ignite.internal.binary.BinaryObjectImpl
at
org.apache.kafka.connect.converters.ByteArrayConverter.fromConnectData(ByteArrayConverter.java:58)
at
org.apache.kafka.connect.runtime.WorkerSourceTask.lambda$convertTransformedRecord$1(WorkerSourceTask.java:267)
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
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
