Hi
I try to use Apache NiFi Stateless Kafka Connector , but encounter a
error even with a simple flow (only LogAttribute processor)
[2023-09-14 17:49:04,171] ERROR Failed to trigger
LogAttribute[id=20111560-2427-338a-839a-782c588a6cec]
(org.apache.nifi.stateless.flow.StandardStatelessFlowCurrent:97)
java.lang.NoSuchMethodError: 'org.slf4j.spi.LoggingEventBuilder
org.slf4j.Logger.makeLoggingEventBuilder(org.slf4j.event.Level)'
at
org.apache.nifi.processor.SimpleProcessLogger.log(SimpleProcessLogger.java:581)
at
org.apache.nifi.processor.SimpleProcessLogger.info(SimpleProcessLogger.java:212)
at
org.apache.nifi.processor.SimpleProcessLogger.info(SimpleProcessLogger.java:240)
at
org.apache.nifi.controller.TerminationAwareLogger.info(TerminationAwareLogger.java:178)
at
org.apache.nifi.processors.standard.LogAttribute.processFlowFile(LogAttribute.java:270)
at
org.apache.nifi.processors.standard.LogAttribute.onTrigger(LogAttribute.java:365)
at
org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at
org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1361)
at
org.apache.nifi.stateless.flow.StandardStatelessFlowCurrent.trigger(StandardStatelessFlowCurrent.java:203)
at
org.apache.nifi.stateless.flow.StandardStatelessFlowCurrent.triggerRootConnectables(StandardStatelessFlowCurrent.java:136)
at
org.apache.nifi.stateless.flow.StandardStatelessFlowCurrent.triggerFlow(StandardStatelessFlowCurrent.java:65)
at
org.apache.nifi.stateless.flow.StandardStatelessFlow.executeDataflow(StandardStatelessFlow.java:500)
at
org.apache.nifi.stateless.flow.StandardStatelessFlow.lambda$trigger$5(StandardStatelessFlow.java:479)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
Looks like it is caused by different versions of slf4j libraries used by
kafka and nifi
Any ideas how can I fix this?
Thanks,
Oleg
