kafka封装类,简单封装了kafka的订阅和发布,方便订阅数据