This interface defines the methods that the source of data for a pipe must define. These methods are used to allow the source to easily be connected to a sink.-This interface defines the methods that the source of data for a pipe must define. These

Interface for a sink for binary output.

Writable sink channel used to write to a pipe.

Distributed Mobile Sink Routing for Wireless Sensor Networks A Survey

kafka0.10->flume1.8->elasticsearch 6.0 自定义日志解析类，自定义索引名,Kafkasource 修改从最后ｏｆｆｓｅｔ开始读。　(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.)