kafka collector(http, tcp)