chaneyLee95 opened a new issue, #157:
URL: https://github.com/apache/rocketmq-eventbridge/issues/157
部署时候提示 topic 创建失败，看源码使用 rockemq-tools 包里 DefaultMQAdminExt.createTopic
这个方法创建的，这个方法是不是只对自建 rocketmq 有效，云上的 rocketMq4/5 不支持
D:\Java\jdk11\bin\java.exe "-javaagent:D:\IntelliJ IDEA Community Edition
2022.2\lib\idea_rt.jar=64181:D:\IntelliJ IDEA Community Edition 2022.2\bin"
-Dfile.encoding=UTF-8 -classpath
D:\project\java\rocketmq-eventbridge\start\target\classes;D:\project\java\rocketmq-eventbridge\adapter\persistence\target\classes;D:\maven\apache-maven-3.8.6\repo\org\springframework\spring-context\5.0.6.RELEASE\spring-context-5.0.6.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\spring-aop\5.0.6.RELEASE\spring-aop-5.0.6.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\spring-beans\5.0.6.RELEASE\spring-beans-5.0.6.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\spring-expression\5.0.6.RELEASE\spring-expression-5.0.6.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\boot\spring-boot-autoconfigure\2.0.2.RELEASE\spring-boot-autoconfigure-2.0.2.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\boot\spring-boot\2.0.2.RELEASE\sp
ring-boot-2.0.2.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\mybatis\spring\boot\mybatis-spring-boot-starter\2.1.3\mybatis-spring-boot-starter-2.1.3.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\boot\spring-boot-starter-jdbc\2.0.2.RELEASE\spring-boot-starter-jdbc-2.0.2.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\com\zaxxer\HikariCP\2.7.9\HikariCP-2.7.9.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\spring-jdbc\5.0.6.RELEASE\spring-jdbc-5.0.6.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\mybatis\spring\boot\mybatis-spring-boot-autoconfigure\2.1.3\mybatis-spring-boot-autoconfigure-2.1.3.jar;D:\maven\apache-maven-3.8.6\repo\org\mybatis\mybatis\3.5.5\mybatis-3.5.5.jar;D:\maven\apache-maven-3.8.6\repo\org\mybatis\mybatis-spring\2.0.5\mybatis-spring-2.0.5.jar;D:\maven\apache-maven-3.8.6\repo\mysql\mysql-connector-java\5.1.46\mysql-connector-java-5.1.46.jar;D:\maven\apache-maven-3.8.6\repo\com\h2database\h2\1.4.197\h2-1.4.197.jar;D:\maven\apache-maven-3.8.6\rep
o\com\google\guava\guava\23.0\guava-23.0.jar;D:\maven\apache-maven-3.8.6\repo\com\google\code\findbugs\jsr305\1.3.9\jsr305-1.3.9.jar;D:\maven\apache-maven-3.8.6\repo\com\google\errorprone\error_prone_annotations\2.0.18\error_prone_annotations-2.0.18.jar;D:\maven\apache-maven-3.8.6\repo\com\google\j2objc\j2objc-annotations\1.1\j2objc-annotations-1.1.jar;D:\maven\apache-maven-3.8.6\repo\org\codehaus\mojo\animal-sniffer-annotations\1.14\animal-sniffer-annotations-1.14.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\rocketmq\rocketmq-client\5.1.0\rocketmq-client-5.1.0.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\rocketmq\rocketmq-remoting\5.1.0\rocketmq-remoting-5.1.0.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\commons\commons-lang3\3.7\commons-lang3-3.7.jar;D:\maven\apache-maven-3.8.6\repo\io\github\aliyunmq\rocketmq-slf4j-api\1.0.1\rocketmq-slf4j-api-1.0.1.jar;D:\maven\apache-maven-3.8.6\repo\io\github\aliyunmq\rocketmq-logback-classic\1.0.1\rocketmq-logback-classic-1.0.1.jar;D
:\maven\apache-maven-3.8.6\repo\org\awaitility\awaitility\4.1.0\awaitility-4.1.0.jar;D:\maven\apache-maven-3.8.6\repo\org\hamcrest\hamcrest\2.1\hamcrest-2.1.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\rocketmq\rocketmq-tools\5.1.0\rocketmq-tools-5.1.0.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\rocketmq\rocketmq-srvutil\5.1.0\rocketmq-srvutil-5.1.0.jar;D:\maven\apache-maven-3.8.6\repo\commons-cli\commons-cli\1.5.0\commons-cli-1.5.0.jar;D:\maven\apache-maven-3.8.6\repo\com\googlecode\concurrentlinkedhashmap\concurrentlinkedhashmap-lru\1.4.2\concurrentlinkedhashmap-lru-1.4.2.jar;D:\maven\apache-maven-3.8.6\repo\org\yaml\snakeyaml\1.19\snakeyaml-1.19.jar;D:\maven\apache-maven-3.8.6\repo\org\flywaydb\flyway-core\8.5.7\flyway-core-8.5.7.jar;D:\maven\apache-maven-3.8.6\repo\org\flywaydb\flyway-mysql\8.5.7\flyway-mysql-8.5.7.jar;D:\project\java\rocketmq-eventbridge\adapter\rpc\target\classes;D:\maven\apache-maven-3.8.6\repo\org\springframework\spring-web\5.0.6.RELEASE\spring-web-5.
0.6.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\httpcomponents\httpclient\4.5.5\httpclient-4.5.5.jar;D:\maven\apache-maven-3.8.6\repo\commons-codec\commons-codec\1.11\commons-codec-1.11.jar;D:\maven\apache-maven-3.8.6\repo\io\projectreactor\reactor-core\3.1.7.RELEASE\reactor-core-3.1.7.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\reactivestreams\reactive-streams\1.0.2\reactive-streams-1.0.2.jar;D:\project\java\rocketmq-eventbridge\adapter\api\target\classes;D:\maven\apache-maven-3.8.6\repo\jakarta\ws\rs\jakarta.ws.rs-api\2.1.6\jakarta.ws.rs-api-2.1.6.jar;D:\maven\apache-maven-3.8.6\repo\org\glassfish\jersey\core\jersey-common\2.26\jersey-common-2.26.jar;D:\maven\apache-maven-3.8.6\repo\javax\ws\rs\javax.ws.rs-api\2.1\javax.ws.rs-api-2.1.jar;D:\maven\apache-maven-3.8.6\repo\javax\annotation\javax.annotation-api\1.3.2\javax.annotation-api-1.3.2.jar;D:\maven\apache-maven-3.8.6\repo\org\glassfish\hk2\external\javax.inject\2.5.0-b42\javax.inject-2.5.0-b42.jar;D:\maven\apa
che-maven-3.8.6\repo\org\glassfish\hk2\osgi-resource-locator\1.0.1\osgi-resource-locator-1.0.1.jar;D:\maven\apache-maven-3.8.6\repo\io\cloudevents\cloudevents-json-jackson\2.3.0\cloudevents-json-jackson-2.3.0.jar;D:\maven\apache-maven-3.8.6\repo\io\cloudevents\cloudevents-core\2.3.0\cloudevents-core-2.3.0.jar;D:\maven\apache-maven-3.8.6\repo\com\fasterxml\jackson\core\jackson-core\2.9.5\jackson-core-2.9.5.jar;D:\maven\apache-maven-3.8.6\repo\com\fasterxml\jackson\core\jackson-databind\2.9.5\jackson-databind-2.9.5.jar;D:\maven\apache-maven-3.8.6\repo\io\cloudevents\cloudevents-http-basic\2.3.0\cloudevents-http-basic-2.3.0.jar;D:\maven\apache-maven-3.8.6\repo\io\cloudevents\cloudevents-http-restful-ws\2.3.0\cloudevents-http-restful-ws-2.3.0.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\httpcomponents\httpcore\4.4.9\httpcore-4.4.9.jar;D:\maven\apache-maven-3.8.6\repo\org\hibernate\validator\hibernate-validator\6.0.9.Final\hibernate-validator-6.0.9.Final.jar;D:\maven\apache-maven-3.8.
6\repo\javax\validation\validation-api\2.0.1.Final\validation-api-2.0.1.Final.jar;D:\maven\apache-maven-3.8.6\repo\org\jboss\logging\jboss-logging\3.3.2.Final\jboss-logging-3.3.2.Final.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\boot\spring-boot-starter-aop\2.0.2.RELEASE\spring-boot-starter-aop-2.0.2.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\aspectj\aspectjweaver\1.8.13\aspectjweaver-1.8.13.jar;D:\project\java\rocketmq-eventbridge\adapter\runtime\target\classes;D:\maven\apache-maven-3.8.6\repo\io\openmessaging\openmessaging-api\0.3.1-alpha\openmessaging-api-0.3.1-alpha.jar;D:\maven\apache-maven-3.8.6\repo\io\openmessaging\openmessaging-connector\0.1.2\openmessaging-connector-0.1.2.jar;D:\maven\apache-maven-3.8.6\repo\org\slf4j\slf4j-api\1.7.25\slf4j-api-1.7.25.jar;D:\maven\apache-maven-3.8.6\repo\org\reflections\reflections\0.9.10\reflections-0.9.10.jar;D:\maven\apache-maven-3.8.6\repo\org\javassist\javassist\3.19.0-GA\javassist-3.19.0-GA.jar;D:\maven\apache-mave
n-3.8.6\repo\com\google\code\findbugs\annotations\2.0.1\annotations-2.0.1.jar;D:\maven\apache-maven-3.8.6\repo\org\projectlombok\lombok\1.18.20\lombok-1.18.20.jar;D:\maven\apache-maven-3.8.6\repo\commons-io\commons-io\2.8.0\commons-io-2.8.0.jar;D:\project\java\rocketmq-eventbridge\common\target\classes;D:\maven\apache-maven-3.8.6\repo\commons-net\commons-net\3.9.0\commons-net-3.9.0.jar;D:\maven\apache-maven-3.8.6\repo\io\cloudevents\cloudevents-api\2.3.0\cloudevents-api-2.3.0.jar;D:\maven\apache-maven-3.8.6\repo\org\junit\jupiter\junit-jupiter\5.10.1\junit-jupiter-5.10.1.jar;D:\maven\apache-maven-3.8.6\repo\org\junit\jupiter\junit-jupiter-params\5.1.1\junit-jupiter-params-5.1.1.jar;D:\maven\apache-maven-3.8.6\repo\org\junit\jupiter\junit-jupiter-engine\5.1.1\junit-jupiter-engine-5.1.1.jar;D:\maven\apache-maven-3.8.6\repo\org\junit\platform\junit-platform-engine\1.1.1\junit-platform-engine-1.1.1.jar;D:\project\java\rocketmq-eventbridge\adapter\storage\target\classes;D:\maven\apache-m
aven-3.8.6\repo\org\apache\rocketmq\rocketmq-acl\5.1.0\rocketmq-acl-5.1.0.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\rocketmq\rocketmq-proto\2.0.2\rocketmq-proto-2.0.2.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\tomcat\annotations-api\6.0.53\annotations-api-6.0.53.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\rocketmq\rocketmq-common\5.1.0\rocketmq-common-5.1.0.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-all\4.1.24.Final\netty-all-4.1.24.Final.jar;D:\maven\apache-maven-3.8.6\repo\com\github\luben\zstd-jni\1.5.2-2\zstd-jni-1.5.2-2.jar;D:\maven\apache-maven-3.8.6\repo\org\lz4\lz4-java\1.8.0\lz4-java-1.8.0.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-exporter-otlp\1.19.0\opentelemetry-exporter-otlp-1.19.0.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-sdk-trace\1.19.0\opentelemetry-sdk-trace-1.19.0.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-semconv\1.19.0-alpha\opentelemetry-semconv-1.19.0-alpha.jar
;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-sdk-metrics\1.19.0\opentelemetry-sdk-metrics-1.19.0.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-exporter-otlp-common\1.19.0\opentelemetry-exporter-otlp-common-1.19.0.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-exporter-common\1.19.0\opentelemetry-exporter-common-1.19.0.jar;D:\maven\apache-maven-3.8.6\repo\com\squareup\okhttp3\okhttp\4.10.0\okhttp-4.10.0.jar;D:\maven\apache-maven-3.8.6\repo\org\jetbrains\kotlin\kotlin-stdlib\1.2.41\kotlin-stdlib-1.2.41.jar;D:\maven\apache-maven-3.8.6\repo\org\jetbrains\annotations\13.0\annotations-13.0.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-exporter-prometheus\1.19.0-alpha\opentelemetry-exporter-prometheus-1.19.0-alpha.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-sdk\1.19.0\opentelemetry-sdk-1.19.0.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-api\1.19.0\opentelemetr
y-api-1.19.0.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-context\1.19.0\opentelemetry-context-1.19.0.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-sdk-common\1.19.0\opentelemetry-sdk-common-1.19.0.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-sdk-logs\1.19.0-alpha\opentelemetry-sdk-logs-1.19.0-alpha.jar;D:\maven\apache-maven-3.8.6\repo\io\opentelemetry\opentelemetry-api-logs\1.19.0-alpha\opentelemetry-api-logs-1.19.0-alpha.jar;D:\maven\apache-maven-3.8.6\repo\io\grpc\grpc-stub\1.50.0\grpc-stub-1.50.0.jar;D:\maven\apache-maven-3.8.6\repo\io\grpc\grpc-api\1.50.0\grpc-api-1.50.0.jar;D:\maven\apache-maven-3.8.6\repo\io\grpc\grpc-context\1.50.0\grpc-context-1.50.0.jar;D:\maven\apache-maven-3.8.6\repo\io\grpc\grpc-netty-shaded\1.50.0\grpc-netty-shaded-1.50.0.jar;D:\maven\apache-maven-3.8.6\repo\io\perfmark\perfmark-api\0.25.0\perfmark-api-0.25.0.jar;D:\maven\apache-maven-3.8.6\repo\io\grpc\grpc-core\1.50.0\grpc-core-1.50.
0.jar;D:\maven\apache-maven-3.8.6\repo\com\google\android\annotations\4.1.1.4\annotations-4.1.1.4.jar;D:\maven\apache-maven-3.8.6\repo\com\squareup\okio\okio-jvm\3.0.0\okio-jvm-3.0.0.jar;D:\maven\apache-maven-3.8.6\repo\org\jetbrains\kotlin\kotlin-stdlib-jdk8\1.2.41\kotlin-stdlib-jdk8-1.2.41.jar;D:\maven\apache-maven-3.8.6\repo\org\jetbrains\kotlin\kotlin-stdlib-jdk7\1.2.41\kotlin-stdlib-jdk7-1.2.41.jar;D:\maven\apache-maven-3.8.6\repo\commons-validator\commons-validator\1.7\commons-validator-1.7.jar;D:\maven\apache-maven-3.8.6\repo\commons-beanutils\commons-beanutils\1.9.4\commons-beanutils-1.9.4.jar;D:\maven\apache-maven-3.8.6\repo\commons-digester\commons-digester\2.1\commons-digester-2.1.jar;D:\maven\apache-maven-3.8.6\repo\commons-logging\commons-logging\1.2\commons-logging-1.2.jar;D:\maven\apache-maven-3.8.6\repo\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;D:\maven\apache-maven-3.8.6\repo\com\google\protobuf\protobuf-java-util\3.20.1\protobuf-ja
va-util-3.20.1.jar;D:\maven\apache-maven-3.8.6\repo\com\google\protobuf\protobuf-java\3.20.1\protobuf-java-3.20.1.jar;D:\project\java\rocketmq-eventbridge\domain\target\classes;D:\maven\apache-maven-3.8.6\repo\org\springframework\spring-tx\5.0.6.RELEASE\spring-tx-5.0.6.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\spring-context-support\5.0.6.RELEASE\spring-context-support-5.0.6.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\commons\commons-text\1.10.0\commons-text-1.10.0.jar;D:\maven\apache-maven-3.8.6\repo\com\github\ben-manes\caffeine\caffeine\2.9.3\caffeine-2.9.3.jar;D:\maven\apache-maven-3.8.6\repo\org\checkerframework\checker-qual\3.19.0\checker-qual-3.19.0.jar;D:\project\java\rocketmq-eventbridge\infrastructure\target\classes;D:\project\java\rocketmq-eventbridge\test\demo\target\classes;D:\maven\apache-maven-3.8.6\repo\org\springframework\boot\spring-boot-starter-webflux\2.6.6\spring-boot-starter-webflux-2.6.6.jar;D:\maven\apache-maven-3.8.6\repo\o
rg\springframework\boot\spring-boot-starter\2.0.2.RELEASE\spring-boot-starter-2.0.2.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\boot\spring-boot-starter-logging\2.0.2.RELEASE\spring-boot-starter-logging-2.0.2.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\ch\qos\logback\logback-classic\1.2.3\logback-classic-1.2.3.jar;D:\maven\apache-maven-3.8.6\repo\ch\qos\logback\logback-core\1.2.9\logback-core-1.2.9.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\logging\log4j\log4j-to-slf4j\2.10.0\log4j-to-slf4j-2.10.0.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\logging\log4j\log4j-api\2.10.0\log4j-api-2.10.0.jar;D:\maven\apache-maven-3.8.6\repo\org\slf4j\jul-to-slf4j\1.7.25\jul-to-slf4j-1.7.25.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\boot\spring-boot-starter-json\2.0.2.RELEASE\spring-boot-starter-json-2.0.2.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.9.5\jackson-datatype-jdk8-2.9.5.jar;D:\maven\apache-
maven-3.8.6\repo\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.9.5\jackson-datatype-jsr310-2.9.5.jar;D:\maven\apache-maven-3.8.6\repo\com\fasterxml\jackson\module\jackson-module-parameter-names\2.9.5\jackson-module-parameter-names-2.9.5.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\boot\spring-boot-starter-reactor-netty\2.0.2.RELEASE\spring-boot-starter-reactor-netty-2.0.2.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\io\projectreactor\ipc\reactor-netty\0.7.7.RELEASE\reactor-netty-0.7.7.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-codec-http\4.1.24.Final\netty-codec-http-4.1.24.Final.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-codec\4.1.24.Final\netty-codec-4.1.24.Final.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-handler\4.1.24.Final\netty-handler-4.1.24.Final.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-buffer\4.1.24.Final\netty-buffer-4.1.24.Final.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-transport\4.1.24.Final\n
etty-transport-4.1.24.Final.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-resolver\4.1.24.Final\netty-resolver-4.1.24.Final.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-handler-proxy\4.1.24.Final\netty-handler-proxy-4.1.24.Final.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-codec-socks\4.1.24.Final\netty-codec-socks-4.1.24.Final.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-transport-native-epoll\4.1.24.Final\netty-transport-native-epoll-4.1.24.Final-linux-x86_64.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-common\4.1.24.Final\netty-common-4.1.24.Final.jar;D:\maven\apache-maven-3.8.6\repo\io\netty\netty-transport-native-unix-common\4.1.24.Final\netty-transport-native-unix-common-4.1.24.Final.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\spring-webflux\5.0.6.RELEASE\spring-webflux-5.0.6.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\com\jayway\jsonpath\json-path\2.4.0\json-path-2.4.0.jar;D:\maven\apache-maven-3.8.6\repo\net\minidev\json-smart\
2.3\json-smart-2.3.jar;D:\maven\apache-maven-3.8.6\repo\net\minidev\accessors-smart\1.2\accessors-smart-1.2.jar;D:\maven\apache-maven-3.8.6\repo\org\ow2\asm\asm\5.0.4\asm-5.0.4.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\spring-core\5.0.6.RELEASE\spring-core-5.0.6.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\spring-jcl\5.0.6.RELEASE\spring-jcl-5.0.6.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\com\google\code\gson\gson\2.8.9\gson-2.8.9.jar;D:\maven\apache-maven-3.8.6\repo\io\springfox\springfox-swagger2\2.7.0\springfox-swagger2-2.7.0.jar;D:\maven\apache-maven-3.8.6\repo\io\swagger\swagger-annotations\1.5.6\swagger-annotations-1.5.6.jar;D:\maven\apache-maven-3.8.6\repo\io\swagger\swagger-models\1.5.13\swagger-models-1.5.13.jar;D:\maven\apache-maven-3.8.6\repo\com\fasterxml\jackson\core\jackson-annotations\2.9.0\jackson-annotations-2.9.0.jar;D:\maven\apache-maven-3.8.6\repo\io\springfox\springfox-spi\2.7.0\springfox-spi-2.7.0.jar;D:\maven\apache-maven-
3.8.6\repo\io\springfox\springfox-core\2.7.0\springfox-core-2.7.0.jar;D:\maven\apache-maven-3.8.6\repo\io\springfox\springfox-schema\2.7.0\springfox-schema-2.7.0.jar;D:\maven\apache-maven-3.8.6\repo\io\springfox\springfox-swagger-common\2.7.0\springfox-swagger-common-2.7.0.jar;D:\maven\apache-maven-3.8.6\repo\io\springfox\springfox-spring-web\2.7.0\springfox-spring-web-2.7.0.jar;D:\maven\apache-maven-3.8.6\repo\com\fasterxml\classmate\1.3.4\classmate-1.3.4.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\plugin\spring-plugin-core\1.2.0.RELEASE\spring-plugin-core-1.2.0.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\plugin\spring-plugin-metadata\1.2.0.RELEASE\spring-plugin-metadata-1.2.0.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\mapstruct\mapstruct\1.1.0.Final\mapstruct-1.1.0.Final.jar;D:\maven\apache-maven-3.8.6\repo\io\springfox\springfox-swagger-ui\2.7.0\springfox-swagger-ui-2.7.0.jar;D:\maven\apache-maven-3.8.6\repo\org\springframework\boot\spring-
boot-starter-validation\2.0.2.RELEASE\spring-boot-starter-validation-2.0.2.RELEASE.jar;D:\maven\apache-maven-3.8.6\repo\org\apache\tomcat\embed\tomcat-embed-el\8.5.31\tomcat-embed-el-8.5.31.jar;D:\maven\apache-maven-3.8.6\repo\com\alibaba\fastjson\1.2.83\fastjson-1.2.83.jar;D:\maven\apache-maven-3.8.6\repo\org\opentest4j\opentest4j\1.2.0\opentest4j-1.2.0.jar;D:\maven\apache-maven-3.8.6\repo\org\junit\platform\junit-platform-commons\1.9.2\junit-platform-commons-1.9.2.jar;D:\maven\apache-maven-3.8.6\repo\org\apiguardian\apiguardian-api\1.1.2\apiguardian-api-1.1.2.jar;D:\maven\apache-maven-3.8.6\repo\net\bytebuddy\byte-buddy\1.7.11\byte-buddy-1.7.11.jar
org.apache.rocketmq.eventbridge.Main
. ____ _ __ _ _
/\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
\\/ ___)| |_)| | | | | || (_| | ) ) ) )
' |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot :: (v2.0.2.RELEASE)
2023-12-22
13:43:05.270@@@@@@@@[main]@@INFO@@org.apache.rocketmq.eventbridge.Main[87]@@Starting
Main on 01Z40bb22048902 with PID 49768
(D:\project\java\rocketmq-eventbridge\start\target\classes started by 22048902
in D:\project\java\rocketmq-eventbridge)
2023-12-22
13:43:05.276@@@@@@@@[main]@@INFO@@org.apache.rocketmq.eventbridge.Main[87]@@The
following profiles are active: local
2023-12-22
13:43:05.373@@@@@@@@[main]@@INFO@@o.s.b.w.r.c.AnnotationConfigReactiveWebServerApplicationContext[87]@@Refreshing
org.springframework.boot.web.reactive.context.AnnotationConfigReactiveWebServerApplicationContext@17aad511:
startup date [Fri Dec 22 13:43:05 GMT+08:00 2023]; root of context hierarchy
2023-12-22
13:43:05.397@@@@@@@@[background-preinit]@@WARN@@o.s.h.c.j.Jackson2ObjectMapperBuilder[87]@@For
Jackson Kotlin classes support please add
"com.fasterxml.jackson.module:jackson-module-kotlin" to the classpath
WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by
org.springframework.cglib.core.ReflectUtils$1
(file:/D:/maven/apache-maven-3.8.6/repo/org/springframework/spring-core/5.0.6.RELEASE/spring-core-5.0.6.RELEASE.jar)
to method
java.lang.ClassLoader.defineClass(java.lang.String,byte[],int,int,java.security.ProtectionDomain)
WARNING: Please consider reporting this to the maintainers of
org.springframework.cglib.core.ReflectUtils$1
WARNING: Use --illegal-access=warn to enable warnings of further illegal
reflective access operations
WARNING: All illegal access operations will be denied in a future release
2023-12-22
13:43:08.198@@@@@@@@[main]@@INFO@@o.s.b.f.a.AutowiredAnnotationBeanPostProcessor[87]@@JSR-330
'javax.inject.Inject' annotation found and supported for autowiring
2023-12-22
13:43:08.278@@@@@@@@[main]@@INFO@@o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker[87]@@Bean
'validatorConfiguration' of type
[org.apache.rocketmq.eventbridge.config.ValidatorConfiguration$$EnhancerBySpringCGLIB$$aeb374ac]
is not eligible for getting processed by all BeanPostProcessors (for example:
not eligible for auto-proxying)
2023-12-22
13:43:08.347@@@@@@@@[main]@@INFO@@o.s.c.s.PostProcessorRegistrationDelegate$BeanPostProcessorChecker[87]@@Bean
'validator' of type [org.hibernate.validator.internal.engine.ValidatorImpl] is
not eligible for getting processed by all BeanPostProcessors (for example: not
eligible for auto-proxying)
2023-12-22
13:43:09.429@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/api-destination/createApiDestination],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.apidestination.CreateApiDestinationResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ApiDestinationController.createApiDestination(org.apache.rocketmq.eventbridge.adapter.api.dto.apidestination.CreateApiDestinationRequest)
2023-12-22
13:43:09.431@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/api-destination/updateApiDestination],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.apidestination.UpdateApiDestinationResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ApiDestinationController.updateApiDestination(org.apache.rocketmq.eventbridge.adapter.api.dto.apidestination.UpdateApiDestinationRequest)
2023-12-22
13:43:09.431@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/api-destination/deleteApiDestination],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.apidestination.DeleteApiDestinationResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ApiDestinationController.deleteApiDestination(org.apache.rocketmq.eventbridge.adapter.api.dto.apidestination.DeleteApiDestinationRequest)
2023-12-22
13:43:09.432@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/api-destination/listApiDestinations],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.apidestination.ListApiDestinationsResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ApiDestinationController.listApiDestinations(org.apache.rocketmq.eventbridge.adapter.api.dto.apidestination.ListApiDestinationsRequest)
2023-12-22
13:43:09.433@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/api-destination/getApiDestination],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.apidestination.GetApiDestinationResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ApiDestinationController.getApiDestination(org.apache.rocketmq.eventbridge.adapter.api.dto.apidestination.GetApiDestinationRequest)
2023-12-22
13:43:09.446@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/connection/getConnection],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.connection.GetConnectionResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ConnectionController.getConnection(org.apache.rocketmq.eventbridge.adapter.api.dto.connection.GetConnectionRequest)
2023-12-22
13:43:09.447@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/connection/selectOneConnection],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.connection.GetConnectionResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ConnectionController.selectOneConnection(org.apache.rocketmq.eventbridge.adapter.api.dto.connection.GetConnectionRequest)
2023-12-22
13:43:09.448@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/connection/listEnumsResponse],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.connection.ListEnumsResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ConnectionController.listEnumsResponse()
2023-12-22
13:43:09.448@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/connection/listConnections],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.connection.ListConnectionResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ConnectionController.listConnections(org.apache.rocketmq.eventbridge.adapter.api.dto.connection.ListConnectionRequest)
2023-12-22
13:43:09.449@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/connection/updateConnection],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.connection.UpdateConnectionResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ConnectionController.updateConnection(org.apache.rocketmq.eventbridge.adapter.api.dto.connection.UpdateConnectionRequest)
2023-12-22
13:43:09.449@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/connection/deleteConnection],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.connection.DeleteConnectionResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ConnectionController.deleteConnection(org.apache.rocketmq.eventbridge.adapter.api.dto.connection.DeleteConnectionRequest)
2023-12-22
13:43:09.450@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/connection/createConnection],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.connection.CreateConnectionResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.ConnectionController.createConnection(org.apache.rocketmq.eventbridge.adapter.api.dto.connection.CreateConnectionRequest)
2023-12-22
13:43:09.466@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/bus/createEventBus],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.bus.CreateEventBusResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventBusController.createEventBus(org.apache.rocketmq.eventbridge.adapter.api.dto.bus.CreateEventBusRequest)
2023-12-22
13:43:09.467@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/bus/deleteEventBus],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.bus.DeleteEventBusResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventBusController.deleteEventBus(org.apache.rocketmq.eventbridge.adapter.api.dto.bus.DeleteEventBusRequest)
2023-12-22
13:43:09.468@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/bus/getEventBus],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.bus.GetEventBusResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventBusController.getEventBus(org.apache.rocketmq.eventbridge.adapter.api.dto.bus.GetEventBusRequest)
2023-12-22
13:43:09.469@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/bus/listEventBuses],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.bus.ListEventBusesResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventBusController.listEventBuses(org.apache.rocketmq.eventbridge.adapter.api.dto.bus.ListEventBusesRequest)
2023-12-22
13:43:09.476@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/webhook/putEvents]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.data.PutEventsResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventDataController.putHttpEvents(org.springframework.web.server.ServerWebExchange,java.util.Map<java.lang.String,
java.lang.String>,byte[],java.lang.String)
2023-12-22
13:43:09.477@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/putEvents],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.data.PutEventsResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventDataController.putEvents(java.util.Map<java.lang.String,
java.lang.String>,byte[])
2023-12-22
13:43:09.500@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/rule/createEventRule],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.rule.CreateRuleResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventRuleController.createRule(org.apache.rocketmq.eventbridge.adapter.api.dto.rule.CreateRuleRequest)
2023-12-22
13:43:09.501@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/rule/deleteEventRule],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.rule.DeleteRuleResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventRuleController.deleteRule(org.apache.rocketmq.eventbridge.adapter.api.dto.rule.DeleteRuleRequest)
2023-12-22
13:43:09.502@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/rule/updateEventRule],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.rule.UpdateRuleResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventRuleController.updateRule(org.apache.rocketmq.eventbridge.adapter.api.dto.rule.UpdateRuleRequest)
2023-12-22
13:43:09.502@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/rule/getEventRule],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.rule.GetRuleResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventRuleController.getRule(org.apache.rocketmq.eventbridge.adapter.api.dto.rule.GetRuleRequest)
2023-12-22
13:43:09.503@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/rule/enableEventRule],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.rule.EnableRuleResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventRuleController.enableRule(org.apache.rocketmq.eventbridge.adapter.api.dto.rule.EnableRuleRequest)
2023-12-22
13:43:09.504@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/rule/disableEventRule],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.rule.DisableRuleResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventRuleController.disableRule(org.apache.rocketmq.eventbridge.adapter.api.dto.rule.DisableRuleRequest)
2023-12-22
13:43:09.504@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/rule/listEventRules],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.rule.ListRulesResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventRuleController.listRules(org.apache.rocketmq.eventbridge.adapter.api.dto.rule.ListRulesRequest)
2023-12-22
13:43:09.517@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/source/createEventSource],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.source.CreateEventSourceResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventSourceController.createEventSource(org.apache.rocketmq.eventbridge.adapter.api.dto.source.CreateEventSourceRequest)
2023-12-22
13:43:09.518@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/source/listEventSources],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.source.ListEventSourcesResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventSourceController.listEventSources(org.apache.rocketmq.eventbridge.adapter.api.dto.source.ListEventSourcesRequest)
2023-12-22
13:43:09.519@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/source/updateEventSource],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.source.UpdateEventSourceResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventSourceController.updateEventSource(org.apache.rocketmq.eventbridge.adapter.api.dto.source.UpdateEventSourceRequest)
2023-12-22
13:43:09.520@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/source/deleteEventSource],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.source.DeleteEventSourceResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventSourceController.deleteEventSource(org.apache.rocketmq.eventbridge.adapter.api.dto.source.DeleteEventSourceRequest)
2023-12-22
13:43:09.521@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/source/getEventSource],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.source.GetEventSourceResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventSourceController.getEventSource(org.apache.rocketmq.eventbridge.adapter.api.dto.source.GetEventSourceRequest)
2023-12-22
13:43:09.536@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/target/updateEventTargets],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.target.UpdateTargetsResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventTargetController.updateTargets(org.apache.rocketmq.eventbridge.adapter.api.dto.target.UpdateTargetsRequest)
2023-12-22
13:43:09.537@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/target/deleteEventTargets],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.target.DeleteTargetsResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventTargetController.deleteTargets(org.apache.rocketmq.eventbridge.adapter.api.dto.target.DeleteTargetsRequest)
2023-12-22
13:43:09.538@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/target/createEventTargets],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.target.CreateTargetsResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventTargetController.createTargets(org.apache.rocketmq.eventbridge.adapter.api.dto.target.CreateTargetsRequest)
2023-12-22
13:43:09.539@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/target/listEventTargets],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.target.ListTargetsResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventTargetController.listEventTargets(org.apache.rocketmq.eventbridge.adapter.api.dto.target.ListTargetsRequest)
2023-12-22
13:43:09.547@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.RequestMappingHandlerMapping[87]@@Mapped
"{[/type/listEventTypes],methods=[POST]}" onto public
reactor.core.publisher.Mono<org.apache.rocketmq.eventbridge.adapter.api.dto.type.ListEventTypesResponse>
org.apache.rocketmq.eventbridge.adapter.api.controller.EventTypeController.listEventTypes(org.apache.rocketmq.eventbridge.adapter.api.dto.type.ListEventTypesRequest)
2023-12-22
13:43:09.696@@@@@@@@[main]@@INFO@@o.s.w.r.h.SimpleUrlHandlerMapping[87]@@Mapped
URL path [/webjars/**] onto handler of type [class
org.springframework.web.reactive.resource.ResourceWebHandler]
2023-12-22
13:43:09.697@@@@@@@@[main]@@INFO@@o.s.w.r.h.SimpleUrlHandlerMapping[87]@@Mapped
URL path [/**] onto handler of type [class
org.springframework.web.reactive.resource.ResourceWebHandler]
2023-12-22
13:43:09.835@@@@@@@@[main]@@INFO@@o.s.w.r.r.m.a.ControllerMethodResolver[87]@@Looking
for @ControllerAdvice:
org.springframework.boot.web.reactive.context.AnnotationConfigReactiveWebServerApplicationContext@17aad511:
startup date [Fri Dec 22 13:43:05 GMT+08:00 2023]; root of context hierarchy
2023-12-22
13:43:10.620@@@@@@@@[main]@@WARN@@com.zaxxer.hikari.HikariConfig[1081]@@
hikaricp - idleTimeout is close to or more than maxLifetime, disabling it.
2023-12-22
13:43:10.628@@@@@@@@[main]@@INFO@@com.zaxxer.hikari.HikariDataSource[80]@@
hikaricp - Starting...
2023-12-22
13:43:11.078@@@@@@@@[main]@@INFO@@com.zaxxer.hikari.HikariDataSource[82]@@
hikaricp - Start completed.
2023-12-22
13:43:12.371@@@@@@@@[main]@@INFO@@o.a.r.e.a.p.PersistenceConfig[45]@@getAclRPCHook
key=372f3aSnKgUFz6kD, secret=51u8QY646VYhT7m2
2023-12-22
13:43:14.333@@@@@@@@[main]@@INFO@@o.a.r.e.a.p.PersistenceConfig[45]@@getAclRPCHook
key=372f3aSnKgUFz6kD, secret=51u8QY646VYhT7m2
2023-12-22
13:43:16.037@@@@@@@@[main]@@INFO@@o.f.c.i.license.VersionPrinter[37]@@Flyway
Community Edition 8.5.7 by Redgate
2023-12-22
13:43:16.038@@@@@@@@[main]@@INFO@@o.f.c.i.license.VersionPrinter[37]@@See
what's new here: https://flywaydb.org/documentation/learnmore/releaseNotes#8.5.7
2023-12-22
13:43:16.038@@@@@@@@[main]@@INFO@@o.f.c.i.license.VersionPrinter[37]@@
2023-12-22
13:43:16.091@@@@@@@@[main]@@INFO@@o.f.c.i.d.base.BaseDatabaseType[37]@@Database:
jdbc:mysql://localhost:3306/test (MySQL 8.0)
2023-12-22
13:43:16.184@@@@@@@@[main]@@INFO@@o.f.core.internal.command.DbValidate[37]@@Successfully
validated 9 migrations (execution time 00:00.045s)
2023-12-22
13:43:16.198@@@@@@@@[main]@@INFO@@o.f.core.internal.command.DbMigrate[37]@@Current
version of schema `test`: 9
2023-12-22
13:43:16.200@@@@@@@@[main]@@INFO@@o.f.core.internal.command.DbMigrate[37]@@Schema
`test` is up to date. No migration necessary.
2023-12-22
13:43:16.278@@@@@@@@[main]@@INFO@@o.a.r.e.adapter.runtime.Runtime[68]@@Start
init runtime.
2023-12-22
13:43:16.290@@@@@@@@[main]@@INFO@@EventBridgeRuntimer[48]@@Try to start service
thread:EventBusListener started:false lastThread:Thread[EventBusListener,5,main]
2023-12-22
13:43:16.291@@@@@@@@[main]@@INFO@@EventBridgeRuntimer[55]@@Start service
thread:EventBusListener started:true lastThread:Thread[EventBusListener,5,main]
2023-12-22
13:43:16.350@@@@@@@@[main]@@INFO@@o.a.r.eventbridge.demo.DefaultDemo[62]@@init
demo
2023-12-22
13:43:16.818@@@@@@@@[main]@@ERROR@@o.a.r.e.a.s.r.i.RocketMQMetaService[54]@@Create
topic failed.
org.apache.rocketmq.client.exception.MQClientException: create new topic
failed
For more information, please visit the url,
https://rocketmq.apache.org/docs/bestPractice/06FAQ
at
org.apache.rocketmq.client.impl.MQAdminImpl.createTopic(MQAdminImpl.java:136)
at
org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.createTopic(DefaultMQAdminExtImpl.java:1686)
at
org.apache.rocketmq.tools.admin.DefaultMQAdminExt.createTopic(DefaultMQAdminExt.java:115)
at
org.apache.rocketmq.tools.admin.DefaultMQAdminExt.createTopic(DefaultMQAdminExt.java:109)
at
org.apache.rocketmq.eventbridge.adapter.storage.rocketmq.impl.RocketMQMetaService.createTopic(RocketMQMetaService.java:52)
at
org.apache.rocketmq.eventbridge.adapter.storage.rocketmq.impl.RocketMQEventDataRepository.createEventBusPersistence(RocketMQEventDataRepository.java:61)
at
org.apache.rocketmq.eventbridge.adapter.storage.rocketmq.impl.RocketMQEventDataRepository$$FastClassBySpringCGLIB$$295ff501.invoke(<generated>)
at
org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
at
org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:746)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
at
org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:139)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185)
at
org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688)
at
org.apache.rocketmq.eventbridge.adapter.storage.rocketmq.impl.RocketMQEventDataRepository$$EnhancerBySpringCGLIB$$3f9f84f.createEventBusPersistence(<generated>)
at
org.apache.rocketmq.eventbridge.domain.model.bus.EventBusService.createEventBus(EventBusService.java:67)
at
org.apache.rocketmq.eventbridge.domain.model.bus.EventBusService$$FastClassBySpringCGLIB$$86839a9d.invoke(<generated>)
at
org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204)
at
org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:746)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
at
org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:294)
at
org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98)
at
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185)
at
org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688)
at
org.apache.rocketmq.eventbridge.domain.model.bus.EventBusService$$EnhancerBySpringCGLIB$$e344c31f.createEventBus(<generated>)
at
org.apache.rocketmq.eventbridge.demo.DefaultDemo.initEventBus(DefaultDemo.java:74)
at
org.apache.rocketmq.eventbridge.demo.DefaultDemo.initDemo(DefaultDemo.java:63)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at
org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleElement.invoke(InitDestroyAnnotationBeanPostProcessor.java:365)
at
org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleMetadata.invokeInitMethods(InitDestroyAnnotationBeanPostProcessor.java:308)
at
org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessBeforeInitialization(InitDestroyAnnotationBeanPostProcessor.java:135)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsBeforeInitialization(AbstractAutowireCapableBeanFactory.java:422)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1698)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:579)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:501)
at
org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:317)
at
org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:228)
at
org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:315)
at
org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199)
at
org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:760)
at
org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:869)
at
org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:550)
at
org.springframework.boot.web.reactive.context.ReactiveWebServerApplicationContext.refresh(ReactiveWebServerApplicationContext.java:61)
at
org.springframework.boot.SpringApplication.refresh(SpringApplication.java:759)
at
org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:395)
at
org.springframework.boot.SpringApplication.run(SpringApplication.java:327)
at org.apache.rocketmq.eventbridge.Main.main(Main.java:30)
Caused by: org.apache.rocketmq.client.exception.MQClientException: create
topic to broker exception
For more information, please visit the url,
https://rocketmq.apache.org/docs/bestPractice/06FAQ
at
org.apache.rocketmq.client.impl.MQAdminImpl.createTopic(MQAdminImpl.java:115)
... 48 common frames omitted
Caused by: org.apache.rocketmq.client.exception.MQClientException: CODE: 16
DESC: cannot find the metadata of this topic
eventbridge%default%demo-bus_1703223796450 NOT_FOUND
For more information, please visit the url,
https://rocketmq.apache.org/docs/bestPractice/06FAQ
at
org.apache.rocketmq.client.impl.MQClientAPIImpl.createTopic(MQClientAPIImpl.java:401)
at
org.apache.rocketmq.client.impl.MQAdminImpl.createTopic(MQAdminImpl.java:109)
... 48 common frames omitted
2023-12-22
13:43:16.829@@@@@@@@[main]@@WARN@@o.s.b.w.r.c.AnnotationConfigReactiveWebServerApplicationContext[87]@@Exception
encountered during context initialization - cancelling refresh attempt:
org.springframework.beans.factory.BeanCreationException: Error creating bean
with name 'defaultDemo': Invocation of init method failed; nested exception is
org.apache.rocketmq.eventbridge.exception.EventBridgeException: InternalError
2023-12-22
13:43:16.841@@@@@@@@[main]@@INFO@@com.zaxxer.hikari.HikariDataSource[381]@@
hikaricp - Shutdown initiated...
2023-12-22
13:43:16.847@@@@@@@@[main]@@INFO@@com.zaxxer.hikari.HikariDataSource[383]@@
hikaricp - Shutdown completed.
2023-12-22
13:45:15.702@@@@@@@@[Thread-13]@@INFO@@o.a.r.e.adapter.runtime.Runtime[83]@@try
to shutdown server
Process finished with exit code 130
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
