4o A BCDEF GH IJ IK LM NOP NQRS T NUV WX YZ[\logLorg/slf4j/Logger;registry@Lorg/springframework/kafka/config/KafkaListenerEndpointRegistry;C(Lorg/springframework/kafka/config/KafkaListenerEndpointRegistry;)VCodeLineNumberTableLocalVariableTablethis+Lcom/artfess/uc/kafka/KafkaConsumerStarter;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired;onApplicationEventA(Lorg/springframework/boot/context/event/ApplicationReadyEvent;)V container=Lorg/springframework/kafka/listener/MessageListenerContainer; listenerIdLjava/lang/String; listenerIds[Ljava/lang/String;eLjava/lang/Exception;event>Lorg/springframework/boot/context/event/ApplicationReadyEvent; StackMapTableXV-C]R1(Lorg/springframework/context/ApplicationEvent;)V()V SignatureLjava/lang/Object;Lorg/springframework/context/ApplicationListener; SourceFileKafkaConsumerStarter.java*Lorg/springframework/stereotype/Component; ; java/lang/StringorgListenerContaineruserListenerContainerroleListenerContainer^ _`] ab c; #Kafka Listener [{}] 已手动启动d ef,Kafka Listener [{}] 未注册或已在运行 gfjava/lang/ExceptionKafkaListener 启动异常:{} hi jkorg/springframework/kafka/config/KafkaListenerEndpointRegistrygetListenerContainerQ(Ljava/lang/String;)Lorg/springframework/kafka/listener/MessageListenerContainer; isRunning()Zstartorg/slf4j/Loggerinfo'(Ljava/lang/String;Ljava/lang/Object;)Vwarn getMessage()Ljava/lang/String;error9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Vorg/slf4j/LoggerFactory getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;!F **+  ! "# $%&'KYSYSYSM,N-66K-2:*:#      M ,,lo 2 !'*(5)D*K+Z-f'l2o0p13!>51()*<*+X,-p./"#01253455<67 34B8A&93 *+ !  "#:;!   <=>?$@