I'm trying to configure MiNiFi to send data to Kafka instead of to a NiFi
remote process group and built a flow using PublishKafka_0_10. When I tried to
start it I got the following error in my logs:
o.apache.nifi.controller.FlowController Could not create Processor of type
org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_10 for ID e1141f47-b1b
8-363a-0000-000000000000; creating "Ghost" implementation
org.apache.nifi.controller.exception.ProcessorInstantiationException: Unable to
find bundle for coordinate default:unknown:unversioned
at
org.apache.nifi.controller.FlowController.instantiateProcessor(FlowController.java:1162)
at
org.apache.nifi.controller.FlowController.createProcessor(FlowController.java:1080)
at
org.apache.nifi.controller.FlowController.createProcessor(FlowController.java:1053)
at
org.apache.nifi.controller.StandardFlowSynchronizer.addProcessGroup(StandardFlowSynchronizer.java:1054)
at
org.apache.nifi.controller.StandardFlowSynchronizer.sync(StandardFlowSynchronizer.java:312)
at
org.apache.nifi.controller.FlowController.synchronize(FlowController.java:1544)
at
org.apache.nifi.persistence.StandardXMLFlowConfigurationDAO.load(StandardXMLFlowConfigurationDAO.java:84)
at
org.apache.nifi.controller.StandardFlowService.loadFromBytes(StandardFlowService.java:720)
at
org.apache.nifi.controller.StandardFlowService.load(StandardFlowService.java:533)
at org.apache.nifi.minifi.MiNiFiServer.start(MiNiFiServer.java:113)
at org.apache.nifi.minifi.MiNiFi.<init>(MiNiFi.java:140)
at org.apache.nifi.minifi.MiNiFi.main(MiNiFi.java:239)
The documentation for the C++ agent includes a list of supported processors,
but I can't find a list of supported processors for MiNiFi Java 0.2.0 anywhere.
Does such a list exist?
Is there an alternate way of getting MiNiFi to publish to Kafka, or can MiNiFi
only send to NiFi?
Best,
Jeremy