Flume配置Socket输入源HBase+Kafka输出源
本文的Flume输入源为netcat输出为HBase和Kafka，其中需要为HBase实现相应的方法。配置如下：a1.sources = r1a1.channels = kafkaC hbaseCa1.sinks = kafkaSink hbaseSinka1.sources.r1.type = avro a1.sources.r1.channels = hba...
