Kafka Sources
a3.sources.r1.type = org.apache.flume.source.kafka.KafkaSource a3.sources.r1.batchSize = 5000 a3.sources.r1.batchDurationMillis = 2000 a3.sources.r1.kafka.bootstrap.servers = hadoop102:9092,hadoop103:9092,hadoop104:9092 a3.sources.r1.kafka.topics = business_db a3.sources.r1.kafka.consumer.group.id = business-flume a3.sources.r1.setTopicHeader = false a3.sources.r1.interceptors = i1 a3.sources.r1.interceptors.i1.type = com.atguigu.interceptor.business_db.ETLTimestampInterceptor$Builder a3.sources.r1.interceptors = i2 a3.sources.r1.interceptors.i2.type = com.atguigu.interceptor.user_log.TableNameInterceptor$Builder
TailDir Source
a1.sources.r1.type = TAILDIR a1.sources.r1.filegroups = f1 a1.sources.r1.filegroups.f1 = /opt/module/data_mocker/log/app.* a1.sources.r1.positionFile = /opt/module/flume-1.9.0/position/taildir_position.json a1.sources.r1.interceptors = i1 a1.sources.r1.interceptors.i1.type = com.atguigu.interceptor.business_db.ETLTimestampInterceptor$Builder
标签：常用,r1,sources,interceptors,a1,source,a3,type From： https://www.cnblogs.com/averyve/p/16629457.html