{"state":"FAILED","trace":"org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:230)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:156)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.convertTransformedRecord(AbstractWorkerSourceTask.java:494)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.sendRecords(AbstractWorkerSourceTask.java:402)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.execute(AbstractWorkerSourceTask.java:367)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.run(AbstractWorkerSourceTask.java:77)\n\tat org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:237)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1583)\nCaused by: org.apache.kafka.common.config.ConfigException: Failed to access Avro data from topic cdc.addy_salepro_prod.products : Schema being registered is incompatible with an earlier schema for subject \"cdc.addy_salepro_prod.products-value\", details: [{errorType:'MISSING_UNION_BRANCH', description:'The new schema is missing a type inside a union field at path '/fields/0/type/1' in the old schema', additionalInfo:'reader union lacking writer type: RECORD'}, {errorType:'MISSING_UNION_BRANCH', description:'The new schema is missing a type inside a union field at path '/fields/1/type/1' in the old schema', additionalInfo:'reader union lacking writer type: RECORD'}, {oldSchemaVersion: 1}, {oldSchema: '{\"type\":\"record\",\"name\":\"Envelope\",\"namespace\":\"cdc.addy_salepro_prod.products\",\"fields\":[{\"name\":\"before\",\"type\":[\"null\",{\"type\":\"record\",\"name\":\"Value\",\"fields\":[{\"name\":\"id\",\"type\":\"string\"},{\"name\":\"add_ons_product_ids\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"attribute_value_ids\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"barcode\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"code\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"content\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"created_date\",\"type\":[\"null\",{\"type\":\"long\",\"connect.version\":1,\"connect.name\":\"org.apache.kafka.connect.data.Timestamp\",\"logicalType\":\"timestamp-millis\"}],\"default\":null},{\"name\":\"description\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"display\",\"type\":[{\"type\":\"int\",\"connect.default\":1,\"connect.type\":\"int16\"},\"null\"],\"default\":1},{\"name\":\"height\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"images\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"import_price\",\"type\":[\"null\",{\"type\":\"bytes\",\"scale\":4,\"precision\":18,\"connect.version\":1,\"connect.parameters\":{\"scale\":\"4\",\"connect.decimal.precision\":\"18\"},\"connect.name\":\"org.apache.kafka.connect.data.Decimal\",\"logicalType\":\"decimal\"}],\"default\":null},{\"name\":\"inventory_status\",\"type\":[{\"type\":\"string\",\"connect.version\":1,\"connect.parameters\":{\"allowed\":\"IN_STOCK,OUT_OF_STOCK,PRE_ORDER\"},\"connect.default\":\"IN_STOCK\",\"connect.name\":\"io.debezium.data.Enum\"},\"null\"],\"default\":\"IN_STOCK\"},{\"name\":\"is_have_children\",\"type\":[{\"type\":\"int\",\"connect.default\":0,\"connect.type\":\"int16\"},\"null\"],\"default\":0},{\"name\":\"length\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"master_id\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"merchant_product_id\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"modified_date\",\"type\":[\"null\",{\"type\":\"long\",\"connect.version\":1,\"connect.name\":\"org.apache.kafka.connect.data.Timestamp\",\"logicalType\":\"timestamp-millis\"}],\"default\":null},{\"name\":\"name\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"old_price\",\"type\":[\"null\",{\"type\":\"bytes\",\"scale\":4,\"precision\":18,\"connect.version\":1,\"connect.parameters\":{\"scale\":\"4\",\"connect.decimal.precision\":\"18\"},\"connect.name\":\"org.apache.kafka.connect.data.Decimal\",\"logicalType\":\"decimal\"}],\"default\":null},{\"name\":\"other_name\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"parent_id\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"price\",\"type\":[\"null\",{\"type\":\"bytes\",\"scale\":4,\"precision\":18,\"connect.version\":1,\"connect.parameters\":{\"scale\":\"4\",\"connect.decimal.precision\":\"18\"},\"connect.name\":\"org.apache.kafka.connect.data.Decimal\",\"logicalType\":\"decimal\"}],\"default\":null},{\"name\":\"product_code\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"product_combo\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"quantity_on_hand\",\"type\":[{\"type\":\"int\",\"connect.default\":0},\"null\"],\"default\":0},{\"name\":\"recommended_product_id\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"search_text\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"status\",\"type\":[{\"type\":\"string\",\"connect.version\":1,\"connect.parameters\":{\"allowed\":\"ACTIVE,INACTIVE,DELETED,DISCONTINUED,UPCOMING,IN_PROGRESS,COMPLETED,EVENT_CANCELLED,POSTPONED,OVERDUE\"},\"connect.default\":\"ACTIVE\",\"connect.name\":\"io.debezium.data.Enum\"},\"null\"],\"default\":\"ACTIVE\"},{\"name\":\"type\",\"type\":[{\"type\":\"string\",\"connect.version\":1,\"connect.parameters\":{\"allowed\":\"PRODUCT,SERVICE,TOPPING,ACCESSORY,MEMBERSHIP,DIGITAL_DOWNLOAD,GIFT_CARD,SUBSCRIPTION,FOOD,SOFTWARE,BOOK,ELECTRONICS,FURNITURE,COMBO,EVENT,COURSE\"},\"connect.default\":\"PRODUCT\",\"connect.name\":\"io.debezium.data.Enum\"},\"null\"],\"default\":\"PRODUCT\"},{\"name\":\"unit\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"vat\",\"type\":[\"null\",{\"type\":\"bytes\",\"scale\":4,\"precision\":18,\"connect.version\":1,\"connect.parameters\":{\"scale\":\"4\",\"connect.decimal.precision\":\"18\"},\"connect.name\":\"org.apache.kafka.connect.data.Decimal\",\"logicalType\":\"decimal\"}],\"default\":null},{\"name\":\"warranty\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"warranty_address\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"warranty_content\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"warranty_phone\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"weight\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"wholesale_price\",\"type\":[\"null\",{\"type\":\"bytes\",\"scale\":4,\"precision\":18,\"connect.version\":1,\"connect.parameters\":{\"scale\":\"4\",\"connect.decimal.precision\":\"18\"},\"connect.name\":\"org.apache.kafka.connect.data.Decimal\",\"logicalType\":\"decimal\"}],\"default\":null},{\"name\":\"width\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"file_metadata_id\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"organization_id\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"category_id\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"warehouse_id\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"order_number\",\"type\":[{\"type\":\"int\",\"connect.default\":0},\"null\"],\"default\":0},{\"name\":\"total_returns\",\"type\":[{\"type\":\"int\",\"connect.default\":0},\"null\"],\"default\":0},{\"name\":\"total_sales\",\"type\":[{\"type\":\"int\",\"connect.default\":0},\"null\"],\"default\":0},{\"name\":\"product_source\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"end_date\",\"type\":[\"null\",{\"type\":\"long\",\"connect.version\":1,\"connect.name\":\"org.apache.kafka.connect.data.Timestamp\",\"logicalType\":\"timestamp-millis\"}],\"default\":null},{\"name\":\"start_date\",\"type\":[\"null\",{\"type\":\"long\",\"connect.version\":1,\"connect.name\":\"org.apache.kafka.connect.data.Timestamp\",\"logicalType\":\"timestamp-millis\"}],\"default\":null},{\"name\":\"url\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"max_stock_threshold\",\"type\":[{\"type\":\"int\",\"connect.default\":0},\"null\"],\"default\":0},{\"name\":\"min_stock_threshold\",\"type\":[{\"type\":\"int\",\"connect.default\":0},\"null\"],\"default\":0}],\"connect.name\":\"cdc.addy_salepro_prod.products.Value\"}],\"default\":null},{\"name\":\"after\",\"type\":[\"null\",\"Value\"],\"default\":null},{\"name\":\"source\",\"type\":{\"type\":\"record\",\"name\":\"Source\",\"namespace\":\"io.debezium.connector.mariadb\",\"fields\":[{\"name\":\"version\",\"type\":\"string\"},{\"name\":\"connector\",\"type\":\"string\"},{\"name\":\"name\",\"type\":\"string\"},{\"name\":\"ts_ms\",\"type\":\"long\"},{\"name\":\"snapshot\",\"type\":[{\"type\":\"string\",\"connect.version\":1,\"connect.parameters\":{\"allowed\":\"true,last,false,incremental\"},\"connect.default\":\"false\",\"connect.name\":\"io.debezium.data.Enum\"},\"null\"],\"default\":\"false\"},{\"name\":\"db\",\"type\":\"string\"},{\"name\":\"sequence\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"ts_us\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"ts_ns\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"table\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"server_id\",\"type\":\"long\"},{\"name\":\"gtid\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"file\",\"type\":\"string\"},{\"name\":\"pos\",\"type\":\"long\"},{\"name\":\"row\",\"type\":\"int\"},{\"name\":\"thread\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"query\",\"type\":[\"null\",\"string\"],\"default\":null}],\"connect.name\":\"io.debezium.connector.mariadb.Source\"}},{\"name\":\"transaction\",\"type\":[\"null\",{\"type\":\"record\",\"name\":\"block\",\"namespace\":\"event\",\"fields\":[{\"name\":\"id\",\"type\":\"string\"},{\"name\":\"total_order\",\"type\":\"long\"},{\"name\":\"data_collection_order\",\"type\":\"long\"}],\"connect.version\":1,\"connect.name\":\"event.block\"}],\"default\":null},{\"name\":\"op\",\"type\":\"string\"},{\"name\":\"ts_ms\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"ts_us\",\"type\":[\"null\",\"long\"],\"default\":null},{\"name\":\"ts_ns\",\"type\":[\"null\",\"long\"],\"default\":null}],\"connect.version\":2,\"connect.name\":\"cdc.addy_salepro_prod.products.Envelope\"}'}, {validateFields: 'false', compatibility: 'BACKWARD'}]; error code: 409\n\tat io.confluent.connect.avro.AvroConverter.fromConnectData(AvroConverter.java:98)\n\tat org.apache.kafka.connect.storage.Converter.fromConnectData(Converter.java:67)\n\tat org.apache.kafka.connect.runtime.AbstractWorkerSourceTask.lambda$convertTransformedRecord$6(AbstractWorkerSourceTask.java:494)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:180)\n\tat org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:214)\n\t... 13 more\n","worker_id":"172.19.0.13:8083","generation":48}