exec 방식flume-ng 설정
1157 단어 flume
producer.sources = r1
producer.sinks = k1 k2
producer.channels = c1 c2
# Describe/configure the source
producer.sources.r1.type = exec
producer.sources.r1.command =tail -F /home/tom/job/test/data/test.txt
# Describe the sink
producer.sinks.k1.type = logger
producer.sinks.k2.type = com.thilinamb.flume.sink.KafkaSink3
producer.sinks.k2.topic = producer
producer.sinks.k2.batchSize = 1
producer.sinks.k2.channel = adchannel-1
producer.sinks.k2.brokerList = tom-centos:9092
# Use a channel which buffers events in memory
producer.channels.c1.type = memory
producer.channels.c1.capacity = 10000
producer.channels.c1.transactionCapacity = 1000
producer.channels.c2.type = memory
producer.channels.c2.capacity = 1000
producer.channels.c2.transactionCapacity = 100
# Bind the source and sink to the channel
producer.sources.r1.channels = c1 c2
producer.sources.r1.selector.type = replicating
producer.sinks.k1.channel = c1
producer.sinks.k2.channel = c2
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
exec 방식flume-ng 설정텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.