Originally used activemq, when consumer receives the message, need to establish a messageListener listens, but kafka news is go to the broker to get messages, how to know at this time the broker has a corresponding topic in the news? Because just learning please give directions