https://lists.apache.org/thread/907n11xlvdmckp1045bspzloclthfqsh   As NiFi is a pure Java/JVM application, we use Jython rather than Python for ExecuteScript. This means that you can't import native (CPython, e.g.) modules into your Jython scripts in ExecuteScript consider using ExecuteStreamCommand with a real Python interpreter and script. I'm looking at Py4J to try and bridge the gap ... View more

Just to clarify, what Haimo mentioned is that the ConsumerKafka processor does not use any of NiFi's state management capabilities because the Kafka client maintains the offsets. Regarding the Kafka client... in 0.9.0 I believe it no longer stores offsets in ZooKeeper, and now stores them internally somehow, so that is why you see it connecting directly to the broker and not using ZooKeeper. ... View more