This question needs to be directed to GridGain as long as you're using their product.
- Denis On Mon, Dec 16, 2019 at 10:20 PM ashishb888 <[email protected]> wrote: > 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/ >
