0
HDFS가 포함 된 Flume HTTP 소스를 싱크대로 테스트하고 있습니다. 아래는 사용 된 conf 파일입니다.HTTP 헤더에 헤더 추가 flume
httpagent.sources = httpsource
httpagent.sinks = hdfs-file-sink
httpagent.channels = ch3
httpagent.sources.httpsource.type = http
httpagent.sources.httpsource.bind = address
httpagent.sources.httpsource.handler =org.apache.flume.sink.solr.morphline.BlobHandler httpagent.sources.httpsource.channels = ch3
httpagent.sources.httpsource.port = port
httpagent.sinks.hdfs-file-sink.type = hdfs
httpagent.sinks.hdfs-file-sink.hdfs.path = hdfs://localhost:8020/flume/events
httpagent.sinks.hdfs-file-sink.hdfs.fileType=DataStream
httpagent.sinks.hdfs-file-sink.hdfs.filePrefix = events-
httpagent.sinks.hdfs-file-sink.hdfs.rollInterval = 30
httpagent.sinks.hdfs-file-sink.channel = ch3
httpagent.channels.ch3.type = memory
요청 본문이 HDFS에 저장 중입니다. 그러나 게시물 내용에 HTTP 헤더도 추가하려고합니다. 어떻게해야합니까?