Apache Flume + Hdfs 싱크

Question

HDFS 싱크 용 구분 기호를 추가 할 수 있습니까? 파일이 쓰여지는 시점은 어떻게 기록 분리자를 추가 할 수 있습니까?

tier1.sinks.hdfssink.serializer = <your serialization class> 
tier1.sinks.hdfssink.serializer.delimiter = < your delimiter> 

당신은 자세한 내용은 다음 GitHub의 사이트를 참조 할 수 있습니다이 하나보다

tier1.sinks.hdfssink.type = hdfs 
tier1.sinks.hdfssink.channel = memory 
tier1.sinks.hdfssink.hdfs.path=tmp/kafka/%{topic}/%y-%m-%d 
tier1.sinks.hdfssink.hdfs.rollSize=268435456 
tier1.sinks.hdfssink.hdfs.rollCount=0 
tier1.sinks.hdfssink.hdfs.rollInterval = 0 
tier1.sinks.hdfssink.hdfs.useLocalTimeStamp=true 
tier1.sinks.hdfssink.hdfs.fileType=DataStream 
tier1.sinks.hdfssink.hdfs.inUseSuffix=.tmp 
tier1.sinks.hdfssink.hdfs.batchSize=10000 

Answer 1

나는 유사한 것, 그 구성 수로 EventSerializer를 사용 향하다 것 -이 : 다음

는

구성입니다 및 코드 스 니펫.

https://github.com/relistan/flume-serializers

희망이 도움이!