楼主应该缺少一些参数,这里摘自官网,楼主可以参考下: Kafka Source [mw_shl_code=bash,true]tier1.sources.source1.type = org.apache.flume.source.kafka.KafkaSource tier1.sources.source1.channels = channel1 tier1.sources.source1.zookeeperConnect = localhost:2181 tier1.sources.source1.topic = test1 tier1.sources.source1.groupId = flume tier1.sources.source1.kafka.consumer.timeout.ms = 100[/mw_shl_code] Kafka Sink [mw_shl_code=bash,true]a1.sinks.k1.type = org.apache.flume.sink.kafka.KafkaSink a1.sinks.k1.topic = mytopic a1.sinks.k1.brokerList = localhost:9092 a1.sinks.k1.requiredAcks = 1 a1.sinks.k1.batchSize = 20 a1.sinks.k1.channel = c1[/mw_shl_code] Kafka Channel [mw_shl_code=bash,true]a1.channels.channel1.type = org.apache.flume.channel.kafka.KafkaChannel a1.channels.channel1.capacity = 10000 a1.channels.channel1.transactionCapacity = 1000 a1.channels.channel1.brokerList=kafka-2:9092,kafka-3:9092 a1.channels.channel1.topic=channel1 a1.channels.channel1.zookeeperConnect=kafka-1:2181[/mw_shl_code] |
错误应该还有的,提供的不够完整,需要提供完整一些。配置也是。 |