hottime11
12
2019-07-22 17:31:39 작성 2019-07-23 09:42:10 수정됨
0
309

nifi 질문드립니다.


안녕하세요. 서버 및 데이터 분석을 공부중인 대학생입니다.

java 프레임워크 nifi를 공부중에 어려움이 있어서 질문드립니다.

kafka consumer에서 데이터를 받아 nifi를 통해 elasticsearch로 넣어줄려고 시도했습니다.

밑에 flow를 보시면 PutElasticsearchhttp processor는 data를 read했지만 실제 elasticsearch에서는 index가 조회되지 않았습니다.

무엇 때문에 안 되는지, 혹은 더 추가해야할 것이 있는지 묻고 싶습니다.

밑에는 nifi flow, 설정 및 kafka code 사진을 첨부했습니다.


port는 kafka : 9092 / nifi : 8080 / elasticsearch http : 9200 / zookeeper: 2181 입니다.

broker는 개인 컴퓨터 한 대 이며, 주소는 전부 localhost를 이용했습니다.


test 문자열을 전송하는 kafka producer code입니다.


elasticsearch index 조회 결과 입니다. 설정에서 지정한 test1  index가 존재하지 않습니다.


nifi flow입니다.


processor PutElasticsearchhttp의 configuration입니다. Automatically Terminate Relationships은 failure, retry, success에 체크했습니다. 

https -> http 변경해도 안 되었습니다.


processor ConsumeKafka의 configuration입니다. Automatically Terminate Relationships은 success에 체크했습니다. 


1
0
  • 답변 0

  • 로그인을 하시면 답변을 등록할 수 있습니다.