kafka input consume message from earliest pass config file from remote, for example http load input/output/filter from the third party class 4. refactor baseinput in order to write new input easily heartbeat output 6. geoip output to es 2.X log detail error when init failed