GetKafka не получает сообщения в Apache Nifi

Question

Я пытаюсь получить сообщения с помощью процессора GetKafka, но я не могу его получить. Я тестировал потребительские сообщения, используя потребитель командной строки Kafka, и он работает. Я также смог успешно использовать процессор PutKafka для размещения сообщений в теме. Приложил свои настройки, где я установил строку соединения и имя темы Zookeeper. Когда я запускаю поток, я не вижу ошибок в процессорах.

GetKafka Processor

Я вижу исключение в 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] 

Кафка (0,8): 2.10-0.8.2.1, Nifi: 0.7.0 Я пропускаю что-нибудь? Благодарю.

Answer 1

Исключение ушло после перезапуска. GetKafka теперь может получать сообщения по мере их отправки в продюсере. Он не получал предыдущие сообщения в теме (что-то эквивалентное - от начала в потребительской консоли kafka). Я не вижу настройки для процессора.