Data Collector Agent Running on forward machines Manager Running on control node Protos Message format defined for using protocol buffer Flume-protobuf-handler Flume source plugin for handling messages serialized by protobuf