在火箭控制台日志中找到了这个
org.apache.rocketmq.client.exception.MQClientException：CODE：206 DESC：未找到使用者组使用统计信息，因为返回偏移表为空，可能是消费者不使用任何消息
主题名称：BillDayInterestBatchJobDestination_topic
生产环境 者已经发送消息成功，但消费者无法消费 .
[2018-09-07 00:14:09.094] WARN examineConsumeStats exception, billBillDayInterestBatchJobDestination_topic
org.apache.rocketmq.client.exception.MQClientException: CODE: 206 DESC: Not found the consumer group consume stats, because return offset table is empty, maybe the consumer not consume any message
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
at org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.examineConsumeStats(DefaultMQAdminExtImpl.java:259)
at org.apache.rocketmq.tools.admin.DefaultMQAdminExt.examineConsumeStats(DefaultMQAdminExt.java:206)
at org.apache.rocketmq.tools.admin.DefaultMQAdminExt.examineConsumeStats(DefaultMQAdminExt.java:200)
at org.apache.rocketmq.console.service.client.MQAdminExtImpl.examineConsumeStats(MQAdminExtImpl.java:162)
at sun.reflect.GeneratedMethodAccessor113.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:333)
at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:85)
at org.apache.rocketmq.console.aspect.admin.MQAdminAspect.aroundMQAdminMethod(MQAdminAspect.java:63)
at sun.reflect.GeneratedMethodAccessor94.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:629)
at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:618)
at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:70)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:168)
at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:92)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213)
at com.sun.proxy.$Proxy73.examineConsumeStats(Unknown Source)
at org.apache.rocketmq.console.service.impl.ConsumerServiceImpl.queryGroup(ConsumerServiceImpl.java:95)
at org.apache.rocketmq.console.service.impl.ConsumerServiceImpl.queryGroupList(ConsumerServiceImpl.java:82)
at sun.reflect.GeneratedMethodAccessor223.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:333)
at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:85)
at org.apache.rocketmq.console.aspect.admin.MQAdminAspect.aroundMQAdminMethod(MQAdminAspect.java:63)
at sun.reflect.GeneratedMethodAccessor94.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
其他日志都是这样的
[2018-09-07 00:23:37.559] INFO MessageClientIDSetter.getNearlyTimeFromID(msgId)=Fri Sep 07 00:05:08 CST 2018 msgId=AC1028DE258D1BE6F5C31EEADBE80000
[2018-09-07 00:23:41.181] INFO msgId=AC1028DE258D1BE6F5C31EEADBE80000 consumerGroup=billBillDayInterestBatchJobDestination_topic clientId=null
[2018-09-07 00:23:41.186] INFO clientId=172.16.40.222@1536250575203
[2018-09-07 00:23:48.961] INFO msgId=AC1028DE258D1BE6F5C31EEADBE80000 consumerGroup=billBillDayInterestBatchJobDestination_topic clientId=null
[2018-09-07 00:23:48.966] INFO clientId=172.16.40.220@1536250589252
[2018-09-07 00:23:51.136] INFO msgId=AC1028DE258D1BE6F5C31EEADBE80000 consumerGroup=billBillDayInterestBatchJobDestination_topic clientId=null
[2018-09-07 00:23:51.141] INFO clientId=172.16.40.222@1536250575203
[2018-09-07 00:23:51.199] ERROR op=global_exception_handler_print_error
java.lang.RuntimeException: org.apache.rocketmq.client.exception.MQClientException: CODE: 207 DESC: consumer <billBillDayInterestBatchJobDestination_topic> <172.16.40.222@1536250575203> Timeout: org.apache.rocketmq.remoting.exception.RemotingTimeoutException: wait response on the channel <172.16.40.222:33621> timeout, 10000(ms), org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.invokeSyncImpl(NettyRemotingAbstract.java:292)
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
at com.google.common.base.Throwables.propagate(Throwables.java:160)
at org.apache.rocketmq.console.service.impl.MessageServiceImpl.consumeMessageDirectly(MessageServiceImpl.java:193)
at org.apache.rocketmq.console.controller.MessageController.consumeMessageDirectly(MessageController.java:74)
at sun.reflect.GeneratedMethodAccessor250.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:220)
at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:134)
at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:116)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738)