# source, channel and sink statement flume_prod.sources = source1 flume_prod.channels = channel1 flume_prod.sinks = sink1 # link source to sink via channel flume_prod.sources.source1.channels = channel1 flume_prod.sinks.sink1.channel = channel1 # source configuration flume_prod.sources.source1.type = org.apache.flume.source.kafka.KafkaSource flume_prod.sources.source1.batchSize = 7000 flume_prod.sources.source1.batchDurationMillis =
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)