Andrew,
Thanks for writing. _Nifi:_ nifi-0.6.1 _Kafka:_ kafka_2.11-0.10.0.0 startup with no changes to configs: # Kafka: bin/zookeeper-server-start.sh config/zookeeper.properties & bin/kafka-server-start.sh config/server.properties & # # create a topic # bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test [...] _Nifi's zookeeper.properties:_ clientPort=2181 initLimit=10 autopurge.purgeInterval=24 syncLimit=5 tickTime=2000 dataDir=./state/zookeeper autopurge.snapRetainCount=30 # # server.1=nifi-node1-hostname:2888:3888 # server.2=nifi-node2-hostname:2888:3888 # server.3=nifi-node3-hostname:2888:3888 # **server.1= ** ^^^^^^ Even though I have: _nifi.state.management.embedded.zookeeper.start=**false** _ I filled in the above setting... changing it to: **server.1=localhost:2888:3888 ** ...which made no difference, of course... Any thoughts? Thanks! [pat](http://about.me/PatTrainor) ( ͡° ͜ʖ ͡°) On Jun 11 2016, at 12:17 pm, Andrew Grande <apere...@gmail.com> wrote: > Pat, which NiFi version is that? Which Kafka broker version on the other end? > > > > Andrew > > > > On Sat, Jun 11, 2016 at 12:15 PM Pat Trainor <[pat.trai...@gmail.com](mailto:pat.trai...@gmail.com)> wrote: > >> Users, >> >> >> >> Has anyone come across PutKafka simply not wanting to send to Kafka? >> >> >> >> In this troubleshooting, I have replicated symptoms in the simplest way I can-with a GenerateFlowFile and a PutKafka: >> >> >> >>  >> >> With a known good Kafka running (other /producers using the same Topic)... >> >> ...yields: >> >> Auto refresh started >> >> 11:17:19 EDT WARNING 2b76634c-6354-4c3c-b977-86f73d64efbcPutKafka[id=2b7663 4c-6354-4c3c-b977-86f73d64efbc] Processor Administratively Yielded for 1 sec due to processing failure >> >> 11:18:00 EDT ERROR 2b76634c-6354-4c3c-b977-86f73d64efbcPutKafka[id=2b76634c -6354-4c3c-b977-86f73d64efbc] Failed while waiting for acks from Kafka >> >> 11:18:00 EDT ERROR 2b76634c-6354-4c3c-b977-86f73d64efbcPutKafka[id=2b76634c -6354-4c3c-b977-86f73d64efbc] PutKafka[id=2b76634c-6354-4c3c-b977-86f73d64efbc] failed to process due to java.lang.NullPointerException; rolling back session: java.lang.NullPointerException >> >> 11:18:00 EDT ERROR 2b76634c-6354-4c3c-b977-86f73d64efbc >> >> PutKafka[id=2b76634c-6354-4c3c-b977-86f73d64efbc] PutKafka[id=2b76634c-6354-4c3c-b977-86f73d64efbc] failed to process session due to java.lang.NullPointerException: java.lang.NullPointerException >> >> >> >> Everything is super-stock, out of the box, and not customized. In fact, I tested Kafka with the Apache test consumer/producer pair, and am trying to send to the same topic, same consumer, still running, after it worked for the test producer. >> >> >> >> Funny thing is, I see this error in forums/emails lately, but nobody nails it down as to why it is occurring... >> >> >> >> ==> nifi-app.log <== 2016-06-11 12:04:24,172 WARN [kafka-producer-network-thread | SecondPutKafka2k] org.apache.kafka.common.network.Selector Error in I/O with localhost/[127.0.0.1](http://127.0.0.1) java.io.EOFException: null at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java :62) ~[kafka-clients-0.8.2.2.jar:na] at org.apache.kafka.common.network.Selector.poll(Selector.java:248) ~[kafka- clients-0.8.2.2.jar:na] at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192) [kafka- clients-0.8.2.2.jar:na] at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191) [kafka-clients-0.8.2.2.jar:na] at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122) [kafka-clients-0.8.2.2.jar:na] at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91] >> >> >> >> attached has screenshots... >> >> >> >> I've slowed down the 'schedules', messes with Message Delimiter, and what seems like all the obvious things... This makes me think it is obvious, so on day 2, I'm reaching out to see if any of you have seen/fixed this... >> >> >> >> Thanks! >> >> [pat](http://about.me/PatTrainor) >> >> ( ͡° ͜ʖ ͡°)
