使用postgresql字段类型文本筛选kafka消息时出错

jhkqcmku  于 2021-06-04  发布在  Kafka
关注(0)|答案(2)|浏览(351)

error | | workersourcetask{id=ptlëu connector-0}任务引发了未捕获且不可恢复的异常[org.apache.kafka.connect.runtime.workertask]org.apache.kafka.connect.errors.connectexception:处的错误处理程序超出了容差org.apache.kafka.connect.runtime.errors.retrywithtoleranceoperator.execandhandleerror(retrywithtoleranceoperator)。java:178)位于org.apache.kafka.connect.runtime.errors.retrywithtoleranceoperator.execute(retrywithtoleranceoperator)。java:104)在org.apache.kafka.connect.runtime.transformationchain.apply(transformationchain。java:50)在org.apache.kafka.connect.runtime.workersourcetask.sendrecords(workersourcetask。java:320)在org.apache.kafka.connect.runtime.workersourcetask.execute(workersourcetask。java:245)在org.apache.kafka.connect.runtime.workertask.dorun(workertask。java:184)在org.apache.kafka.connect.runtime.workertask.run(workertask。java:234)在java.base/java.util.concurrent.executors$runnableadapter.call(executors。java:515)在java.base/java.util.concurrent.futuretask.run(futuretask。java:264)位于java.base/java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor。java:1128)在java.base/java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor。java:628)在java.base/java.lang.thread.run(线程。java:834)引起原因:io.debezium.debeziumexception:计算表达式'value.after.brandid==branda'for record'sourcerecord{sourcepartition={server=testdev\u ptl005},sourceoffset={last\u snapshot\u record=false,lsn=27649944,txid=707,ts\u usec=159435757369000,snapshot=true}timestamp=null时出错,headers=connectheaders(headers=)}'位于io.debezium.transforms.scripting.jsr223engine.eval(jsr223engine)。java:116)在io.debezium.transforms.filter.doapply(filter。java:33)在io.debezium.transforms.scriptingtransformation.apply(脚本转换)。java:189)在org.apache.kafka.connect.runtime.transformationchain.lambda$apply$0(transformationchain)。java:50)位于org.apache.kafka.connect.runtime.errors.retrywithtoleranceoperator.execandretry(retrywithtoleranceoperator)。java:128)位于org.apache.kafka.connect.runtime.errors.retrywithtoleranceoperator.execandhandleerror(retrywithtoleranceoperator)。java:162) ... 11更多原因:javax.script.scriptexception:groovy.lang.missingpropertyexception:没有这样的属性:branda for class:script1 at org.codehaus.groovy.jsr223.groovyscriptengineimpl.eval(groovyscriptengineimpl)。java:320)在org.codehaus.groovy.jsr223.groovycompiledscript.eval(groovycompiledscript。java:71)在java.scripting/javax.script.compiledscript.eval(compiledscript。java:89)在io.debezium.transforms.scripting.jsr223engine.eval(jsr223engine。java:107) ... 还有16个原因:groovy.lang.missingpropertyexception:没有这样的属性:branda for class:script1 at org.codehaus.groovy.runtime.scriptbytecodeadapter.unwrap(scriptbytecodeadapter)。java:65)在org.codehaus.groovy.runtime.callsite.pogogetpropertysite.getproperty(pogogetpropertysite。java:51)在org.codehaus.groovy.runtime.callsite.abstractcallsite.callgroovyobjectgetproperty(abstractcallsite。java:341)在script1.run(script1。groovy:1)在org.codehaus.groovy.jsr223.groovyscriptengineimpl.eval(groovyscriptengineimpl。java:317) ... 19个以上

im9ewurl

im9ewurl1#

请将jar文件放入连接器(so debezium connector-*)目录
groovy-3.0.4.jar版本
groovy-jsr223-3.0.4.jar版本
groovy-json-3.0.4.jar

mec1mxoz

mec1mxoz2#

你考虑过使用Kafka连接器吗?也许这能帮上忙:https://docs.confluent.io/current/connect/transforms/filter.html

相关问题