GetKafka가 Apache Nifi에서 메시지를 가져 오지 않습니다.

GetKafka 프로세서를 사용하여 메시지를 가져 오려고하는데 가져올 수 없습니다. 나는 Kafka 커맨드 라인 소비자를 사용하여 소비하는 메시지를 테스트했으며 작동한다. 또한 PutKafka 프로세서를 사용하여 메시지를 주제에 넣을 수있었습니다. 사육사 연결 문자열 및 주제 이름을 설정 한 내 설정을 첨부했습니다. 흐름을 실행할 때 프로세서에 오류가 표시되지 않습니다.GetKafka가 Apache Nifi에서 메시지를 가져 오지 않습니다.

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 :

GetKafka Processor

나는 nifi-app.log에서 예외를 참조 0.7.0 난 아무것도없는 건가요? 감사.

출처

2016-08-03 John Doe

Kafka 및 NiFi의 어떤 버전을 사용하고 있습니까? –

Kafka (0.8) : 2.10-0.8.2.1, Nifi : 0.7.0 –

Ok는 DataSlave1.CSE-RD.com에서 NiF가 실행되는 해결 가능한 호스트 이름입니까? –

다시 시작한 후에 예외가 사라졌습니다. GetKafka는 이제 제작자가 보낸 메시지를 가져올 수 있습니다. 주제에서 이전 메시지를 수신하지 못했습니다 (kafka 콘솔 사용자의 --from-beginning와 동일). 프로세서의 설정이 표시되지 않습니다.

출처

2016-08-03 17:57:53

GetKafka가 Apache Nifi에서 메시지를 가져 오지 않습니다.

답변

관련 문제