This is real-time analyzer for kafka in esper. Input is kafka and Processor is Espaer. Output will be plugged in any type, is database or file or other's input.