nifi-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Oxenberg, Jeff" <>
Subject publishmqtt with SSL
Date Wed, 09 Aug 2017 01:32:59 GMT

I’m trying to get NiFi to send mqtt messages to the Azure IoT Hub.  The IoT Hub uses SSL
certificates, and I’m having trouble getting it working with the publishmqtt processor.
 I create a StandardSSLContextService pointing the truststore at /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/security/cacerts.
 I made sure (I think) that the chain was trusted by importing it manually into the cacerts:
openssl s_client -showcerts -connect </dev/null | sed -ne
keytool -import -noprompt -trustcacerts -alias azure -file msft.cert -keystore /usr/lib/jvm/java-8-openjdk-amd64/jre/lib/security/cacerts
-storepass changeit

When I start the processor, I immediately get the below error.  This all works when I do it
manually outside of NiFi using mosquitto_pub, so I know that my various settings (username,
password, etc) are correct.  Has anyone done something similar, or can anyone offer any help

2017-08-08 17:20:28,570 ERROR [StandardProcessScheduler Thread-6] o.a.n.controller.StandardProcessorNode
Failed to invoke @OnScheduled method due to java.lang.RuntimeException: Failed while executing
one of processor's OnScheduled task.
java.lang.RuntimeException: Failed while executing one of processor's OnScheduled task.
        at org.apache.nifi.controller.StandardProcessorNode.invokeTaskAsCancelableFuture(
        at org.apache.nifi.controller.StandardProcessorNode.access$000(
        at org.apache.nifi.controller.StandardProcessorNode$
        at java.util.concurrent.Executors$
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(
        at java.util.concurrent.ScheduledThreadPoolExecutor$
        at java.util.concurrent.ThreadPoolExecutor.runWorker(
        at java.util.concurrent.ThreadPoolExecutor$
Caused by: java.util.concurrent.ExecutionException: java.lang.reflect.InvocationTargetException
        at java.util.concurrent.FutureTask.get(
        at org.apache.nifi.controller.StandardProcessorNode.invokeTaskAsCancelableFuture(
        ... 9 common frames omitted
Caused by: java.lang.reflect.InvocationTargetException: null
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(
        at java.lang.reflect.Method.invoke(


Jeff Oxenberg
View raw message