activeqmq 都是broker push 到 消费者，消费者 建立 messageListener
监听器 就可以 获取消息，但kafka 是 需要去broker pull消息， 怎么才能知道 broker中 已经 有了对应 ｔｏｐｉｃ 呢 ？定时 获取？
broker中的topic信息以及consumer进行pull过程中产生的offset都在zookeeper中有存储，consumer可以连接zookeeper查看对应topic的状态
可以使用spring 集成的kafka的里面MessageListener 连监听消息哦