Consumer code below

 
@ Component 
@ RocketMQMessageListener (
Topic="topicTest", 
ConsumerGroup="consumer - group" 
) 
Public class consumer implements RocketMQListener {

Private Logger Logger=LoggerFactory. GetLogger (getClass ()); 
@ Override 
Public void onMessage (String s) {
Logger. The info (" [onMessage] [Thread number: {} message content: {}] ", Thread. The currentThread () getId (), s); 
} 
} 

The producer sends a message part below

 
@ Test 
Void contextLoads () {
TopicTest rocketMQTemplate. ConvertAndSend (", "" hello springboot rocketmq"); 
System. The out. Println (" send success "); 
} 

Consumers are so written, then the producer sends a message, how customers can't accept the news, what reason be