nifi-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andrew Grande <apere...@gmail.com>
Subject Re: PutKafka won't Put! "Failed while waiting for acks from Kafka"
Date Sat, 11 Jun 2016 16:17:25 GMT
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.trainor@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=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>
> ( ͡° ͜ʖ ͡°)
>
>

Mime
View raw message