@@ -28,7 +28,7 @@ import org.springframework.stereotype.Component;
@RequiredArgsConstructor
@Slf4j
@Component
-@ConditionalOnExpression("'local'.equals('${locationFlag}')")
+@ConditionalOnExpression("'cloud'.equals('${locationFlag}')")
public class KafkaCloudConsumer {
/**
* eventBus主题监听 第三方对接相关