|
@@ -28,7 +28,7 @@ import org.springframework.stereotype.Component;
|
|
|
@RequiredArgsConstructor
|
|
@RequiredArgsConstructor
|
|
|
@Slf4j
|
|
@Slf4j
|
|
|
@Component
|
|
@Component
|
|
|
-@ConditionalOnExpression("'cloud'.equals('${locationFlag}')")
|
|
|
|
|
|
|
+@ConditionalOnExpression("'local'.equals('${locationFlag}')")
|
|
|
public class KafkaCloudConsumer {
|
|
public class KafkaCloudConsumer {
|
|
|
/**
|
|
/**
|
|
|
* eventBus主题监听 第三方对接相关
|
|
* eventBus主题监听 第三方对接相关
|
|
@@ -81,7 +81,7 @@ public class KafkaCloudConsumer {
|
|
|
IYktEventStrategy eventStrategy = SpringUtils.getBean(sender, IYktEventStrategy.class);
|
|
IYktEventStrategy eventStrategy = SpringUtils.getBean(sender, IYktEventStrategy.class);
|
|
|
eventStrategy.doMsgHandle(eventType, eventMsg);
|
|
eventStrategy.doMsgHandle(eventType, eventMsg);
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
|
- log.error("[kafka消息处理失败]-[消息:{}-[错误:{}]", receiveMsg, e.toString());
|
|
|
|
|
|
|
+ log.error("[kafka消息处理失败]-[消息:{}-[错误:{}]", receiveMsg, e);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|