GetKafka nicht erhalten Nachrichten in Apache Nifi

Question

Ich versuche, die Nachrichten mit einem GetKafka-Prozessor zu bekommen, aber ich bin nicht in der Lage, es zu bekommen. Ich habe konsumierende Nachrichten mit dem Kafka-Befehlszeilen-Consumer getestet und es funktioniert. Ich war auch in der Lage, den PutKafka-Prozessor erfolgreich zu verwenden, um die Nachrichten in das Thema zu bringen. An meine Einstellungen angehängt, wo ich die Zookeeper-Verbindungszeichenfolge und den Themennamen eingerichtet habe. Wenn ich den Fluss starte, sehe ich keine Fehler in den Prozessoren.

GetKafka Processor

Ich sehe eine Ausnahme in nifi-app.log:

2016-08-03 09:34:33,722 WARN [70e1df87-6097-4ed0-9a40-7e36f9be6921_mydomain.com-1470231250839-1fbd0cfe-leader-finder-thread] kafka.client.ClientUtils$ Fetching topic metadata with correlation id 0 for topics [Set(test)] from broker [id:0,host:DataSlave1.CSE-RD.com, 
port:9092] failed                                                                 
java.nio.channels.ClosedByInterruptException: null                                                         
     at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:202) ~[na:1.8.0_101]                                       
     at sun.nio.ch.SocketChannelImpl.poll(SocketChannelImpl.java:957) ~[na:1.8.0_101] 

Kafka (0,8): 2.10-0.8.2.1, Nifi: 0.7.0 ich etwas fehle? Vielen Dank.

Answer 1

Die Ausnahme ist nach einem Neustart verschwunden. GetKafka ist jetzt in der Lage, die Nachrichten zu erhalten, wie sie im Hersteller gesendet werden. Es hat die vorherigen Nachrichten im Thema nicht empfangen (etwas, das dem von -from-anfang in kafka console consumer entspricht). Ich sehe keine Einstellung dafür im Prozessor.