搜索资源列表
flume-kafka-storm-sunxing
- 一个基于storm+flume+kafka的可运行程序包(A storm+flume+kafka based executable package)
JavaKafkaConsumerHighAPI
- 自定义简单Kafka消费者,里面有对kafka的简单引用(Customize simple Kafka consumers with a simple reference to Kafka)
flume-es-sink.tar
- kafka0.10->flume1.8->elasticsearch 6.0 自定义日志解析类,自定义索引名,Kafkasource 修改从最后offset开始读。 (Kafka 0.10 to flume 1.8 to elasticsearch 6 Customize the log parsing class, customize the index name, and read the Kafkasource changes from the last offset.)