版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/qq_33733970/article/details/89357073
collector0.sources.sourceKafka1.type = cn.yottabyte.flume.source.kafka.NewKafkaSource
collector0.sources.sourceKafka1.channels = channel1
collector0.sources.sourceKafka1.bootstrapServers = ip1:9092,ip2:9092,ip3:9092
collector0.sources.sourceKafka1.topic = f5-http-kafka
collector0.sources.sourceKafka1.groupId = rzy_collector
collector0.sources.sourceKafka1.appname = f5-http-kafka
collector0.sources.sourceKafka1.tag = kafka
collector0.sources.sourceKafka1.token =
collector0.sources.sourceKafka1.charset = User message charset, default: UTF-8
collector0.sources.sourceKafka1.eventParser = cn.yottabyte.flume.source.kafka.parser.DefaultEventParser
主要改:
collector0.sources.sourceKafka1.topic = f5-http-kafka
collector0.sources.sourceKafka1.appname = f5-http-kafka
collector0.sources.sourceKafka1.tag = kafka
collector0.sources.sourceKafka1.token =