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 <[email protected]> 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=2b76634c-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 > 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> > ( ͡° ͜ʖ ͡°) > >
