ColeSu-n commented on issue #5148: URL: https://github.com/apache/eventmesh/issues/5148#issuecomment-2548054577
源码编译运行eventmesh步骤 1. ```git clone https://github.com/apache/eventmesh.git``` 2. ``` wget https://dlcdn.apache.org/eventmesh/1.10.0/apache-eventmesh-1.10.0-source.tar.gz tar -xvzf apache-eventmesh-1.10.0-source.tar.gz cd apache-eventmesh-1.10.0-src/ ``` 3. ``` pwd apache-eventmesh-1.10.0-src ``` then ``` cp -r ../eventmesh/gradle ./ cp gradlew ./ ``` 4. ```root@node2:~/apache-eventmesh-1.10.0-src# java -Dlog4j.configurationFile=eventmesh-runtime/conf/log4j2.xml -Deventmesh.log.home=eventmesh-runtime/logs -Deventmesh.home=eventmesh-runtime -DconfPath=eventmesh-runtime/conf -cp eventmesh-starter/dist/apps/eventmesh-starter-1.10.0-release.jar:eventmesh-starter/dist/lib/* org.apache.eventmesh.starter.StartUp``` log ``` 2024-12-17 10:08:46,757 INFO [main] BannerUtil(BannerUtil.java:63) - EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEME EMEMEMEME EMEMEMEME EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEME EMEMEMEMEMEMEMEME EMEMEMEMEMEMEMEMEM EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEM EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEME EMEMEMEMEMEM EMEMEMEMEM EMEMEMEMEMEMEMEME EMEMEMEMEME EMEMEMEME EMEMEMEMEM EMEMEMEMEMEME EMEMEMEME EMEMEME EMEMEMEMEM EMEME EMEMEMEM EMEMEME EMEMEMEMEM EMEMEME EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEM EMEMEMEMEM EMEMEME EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEM EMEMEMEMEM EMEMEME EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEM EMEMEMEMEM EMEMEME EMEMEME EMEMEMEMEM EMEMEME EMEMEME EMEMEMEMEM EMEMEME EMEMEMEME EMEMEMEMEM EMEMEMEME EMEMEMEMEMEM EMEMEMEMEM EMEMEMEMEMEM EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEME EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEM EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEM EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEME MEMEMEMEMEMEMEMEMEMEMEMEMEMEME EMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEMEME ____ _ __ __ _ / ____|_ _____ _ __ | |_| \/ | ___ ___| |__ | __|\ \ / / _ | '_ \| __| |\/| |/ _ |/ __| '_ \ | |___ \ V / __| | | | |_| | | | __|\__ \ | | | \ ____| \_/ \___|_| |_|\__|_| |_|\___||___/_| |_| 2024-12-17 10:08:46,806 DEBUG [main] InternalLoggerFactory(InternalLoggerFactory.java:63) - Using SLF4J as the default logging framework 2024-12-17 10:08:46,809 DEBUG [main] PlatformDependent0(PlatformDependent0.java:495) - -Dio.netty.noUnsafe: false 2024-12-17 10:08:46,809 DEBUG [main] PlatformDependent0(PlatformDependent0.java:998) - Java version: 8 2024-12-17 10:08:46,810 DEBUG [main] PlatformDependent0(PlatformDependent0.java:136) - sun.misc.Unsafe.theUnsafe: available 2024-12-17 10:08:46,810 DEBUG [main] PlatformDependent0(PlatformDependent0.java:160) - sun.misc.Unsafe.copyMemory: available 2024-12-17 10:08:46,811 DEBUG [main] PlatformDependent0(PlatformDependent0.java:192) - sun.misc.Unsafe.storeFence: available 2024-12-17 10:08:46,811 DEBUG [main] PlatformDependent0(PlatformDependent0.java:235) - java.nio.Buffer.address: available 2024-12-17 10:08:46,812 DEBUG [main] PlatformDependent0(PlatformDependent0.java:306) - direct buffer constructor: available 2024-12-17 10:08:46,812 DEBUG [main] PlatformDependent0(PlatformDependent0.java:384) - java.nio.Bits.unaligned: available, true 2024-12-17 10:08:46,812 DEBUG [main] PlatformDependent0(PlatformDependent0.java:458) - jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable prior to Java9 2024-12-17 10:08:46,812 DEBUG [main] PlatformDependent0(PlatformDependent0.java:481) - java.nio.DirectByteBuffer.<init>(long, int): available 2024-12-17 10:08:46,813 DEBUG [main] PlatformDependent(PlatformDependent.java:1159) - sun.misc.Unsafe: available 2024-12-17 10:08:46,813 DEBUG [main] PlatformDependent(PlatformDependent.java:1289) - -Dio.netty.tmpdir: /tmp (java.io.tmpdir) 2024-12-17 10:08:46,813 DEBUG [main] PlatformDependent(PlatformDependent.java:1368) - -Dio.netty.bitMode: 64 (sun.arch.data.model) 2024-12-17 10:08:46,814 DEBUG [main] PlatformDependent(PlatformDependent.java:178) - -Dio.netty.maxDirectMemory: 3700424704 bytes 2024-12-17 10:08:46,814 DEBUG [main] PlatformDependent(PlatformDependent.java:185) - -Dio.netty.uninitializedArrayAllocationThreshold: -1 2024-12-17 10:08:46,815 DEBUG [main] CleanerJava6(CleanerJava6.java:92) - java.nio.ByteBuffer.cleaner(): available 2024-12-17 10:08:46,815 DEBUG [main] PlatformDependent(PlatformDependent.java:205) - -Dio.netty.noPreferDirect: false 2024-12-17 10:08:46,838 INFO [main] EventMeshHTTPServer(LogUtils.java:118) - ==================EventMeshHTTPServer Initialing================== 2024-12-17 10:08:46,844 DEBUG [main] NativeLibraryLoader(NativeLibraryLoader.java:78) - -Dio.netty.native.workdir: /tmp (io.netty.tmpdir) 2024-12-17 10:08:46,845 DEBUG [main] NativeLibraryLoader(NativeLibraryLoader.java:83) - -Dio.netty.native.deleteLibAfterLoading: true 2024-12-17 10:08:46,845 DEBUG [main] NativeLibraryLoader(NativeLibraryLoader.java:87) - -Dio.netty.native.tryPatchShadedId: true 2024-12-17 10:08:46,845 DEBUG [main] NativeLibraryLoader(NativeLibraryLoader.java:91) - -Dio.netty.native.detectNativeLibraryDuplicates: true 2024-12-17 10:08:46,858 DEBUG [main] NativeLibraryLoader(NativeLibraryLoader.java:384) - Successfully loaded the library /tmp/libnetty_transport_native_epoll_x86_649148067813781157520.so 2024-12-17 10:08:46,861 DEBUG [main] NetUtil(NetUtil.java:136) - -Djava.net.preferIPv4Stack: false 2024-12-17 10:08:46,862 DEBUG [main] NetUtil(NetUtil.java:137) - -Djava.net.preferIPv6Addresses: false 2024-12-17 10:08:46,863 DEBUG [main] NetUtilInitializations(NetUtilInitializations.java:129) - Loopback interface: lo (lo, 0:0:0:0:0:0:0:1%lo) 2024-12-17 10:08:46,864 DEBUG [main] NetUtil(NetUtil.java:173) - /proc/sys/net/core/somaxconn: 32768 2024-12-17 10:08:46,868 DEBUG [main] MultithreadEventLoopGroup(MultithreadEventLoopGroup.java:44) - -Dio.netty.eventLoopThreads: 8 2024-12-17 10:08:46,882 DEBUG [main] InternalThreadLocalMap(InternalThreadLocalMap.java:86) - -Dio.netty.threadLocalMap.stringBuilder.initialSize: 1024 2024-12-17 10:08:46,882 DEBUG [main] InternalThreadLocalMap(InternalThreadLocalMap.java:89) - -Dio.netty.threadLocalMap.stringBuilder.maxSize: 4096 2024-12-17 10:08:46,893 DEBUG [main] PlatformDependent(PlatformDependent.java:1010) - org.jctools-core.MpscChunkedArrayQueue: available 2024-12-17 10:08:46,899 DEBUG [main] NioEventLoop(NioEventLoop.java:109) - -Dio.netty.noKeySetOptimization: false 2024-12-17 10:08:46,899 DEBUG [main] NioEventLoop(NioEventLoop.java:110) - -Dio.netty.selectorAutoRebuildThreshold: 512 2024-12-17 10:08:46,901 INFO [main] ProducerManager(ProducerManager.java:42) - producerManager inited...... 2024-12-17 10:08:46,906 INFO [main] MetaInfExtensionClassLoader(MetaInfExtensionClassLoader.java:85) - load extension class success, extensionType: interface org.apache.eventmesh.metrics.api.MetricsRegistry, extensionClass: class org.apache.eventmesh.metrics.prometheus.PrometheusMetricsRegistry 2024-12-17 10:08:46,907 INFO [main] EventMeshExtensionFactory(EventMeshExtensionFactory.java:103) - initialize extension instance success, extensionClass: interface org.apache.eventmesh.metrics.api.MetricsRegistry, extensionInstanceName: prometheus 2024-12-17 10:08:46,930 INFO [main] HTTPMetricsServer(LogUtils.java:118) - HTTPMetricsServer initialized. 2024-12-17 10:08:46,964 INFO [main] ConsumerManager(ConsumerManager.java:50) - consumerManager inited...... 2024-12-17 10:08:46,964 INFO [main] ProducerManager(ProducerManager.java:42) - producerManager inited...... 2024-12-17 10:08:46,973 INFO [main] HandlerService(HandlerService.java:110) - path is /eventmesh/publish processor name is SendAsyncEventProcessor 2024-12-17 10:08:46,975 INFO [main] HandlerService(HandlerService.java:110) - path is /eventmesh/bridge/publish processor name is SendAsyncRemoteEventProcessor 2024-12-17 10:08:46,978 INFO [main] HandlerService(HandlerService.java:110) - path is /eventmesh/subscribe/local processor name is LocalSubscribeEventProcessor 2024-12-17 10:08:46,979 INFO [main] HandlerService(HandlerService.java:110) - path is /eventmesh/subscribe/remote processor name is RemoteSubscribeEventProcessor 2024-12-17 10:08:46,981 INFO [main] HandlerService(HandlerService.java:110) - path is /eventmesh/unsubscribe/local processor name is LocalUnSubscribeEventProcessor 2024-12-17 10:08:46,983 INFO [main] HandlerService(HandlerService.java:110) - path is /eventmesh/unsubscribe/remote processor name is RemoteUnSubscribeEventProcessor 2024-12-17 10:08:46,984 INFO [main] HandlerService(HandlerService.java:110) - path is /eventmesh/topic/create processor name is CreateTopicProcessor 2024-12-17 10:08:46,985 INFO [main] HandlerService(HandlerService.java:110) - path is /eventmesh/topic/delete processor name is DeleteTopicProcessor 2024-12-17 10:08:46,986 INFO [main] HandlerService(HandlerService.java:110) - path is /eventmesh/subscrition/query processor name is QuerySubscriptionProcessor 2024-12-17 10:08:46,990 INFO [main] MetaInfExtensionClassLoader(MetaInfExtensionClassLoader.java:85) - load extension class success, extensionType: interface org.apache.eventmesh.api.producer.Producer, extensionClass: class org.apache.eventmesh.storage.rocketmq.producer.RocketMQProducerImpl 2024-12-17 10:08:46,991 INFO [main] MetaInfExtensionClassLoader(MetaInfExtensionClassLoader.java:85) - load extension class success, extensionType: interface org.apache.eventmesh.api.producer.Producer, extensionClass: class org.apache.eventmesh.storage.standalone.producer.StandaloneProducerAdaptor 2024-12-17 10:08:46,991 INFO [main] EventMeshExtensionFactory(EventMeshExtensionFactory.java:133) - initialize extension instance success, extensionType: interface org.apache.eventmesh.api.producer.Producer, extensionName: standalone 2024-12-17 10:08:46,998 INFO [main] MetaInfExtensionClassLoader(MetaInfExtensionClassLoader.java:85) - load extension class success, extensionType: interface org.apache.eventmesh.protocol.api.ProtocolAdaptor, extensionClass: class org.apache.eventmesh.protocol.http.HttpProtocolAdaptor 2024-12-17 10:08:46,999 INFO [main] MetaInfExtensionClassLoader(MetaInfExtensionClassLoader.java:85) - load extension class success, extensionType: interface org.apache.eventmesh.protocol.api.ProtocolAdaptor, extensionClass: class org.apache.eventmesh.protocol.meshmessage.MeshMessageProtocolAdaptor 2024-12-17 10:08:47,000 INFO [main] MetaInfExtensionClassLoader(MetaInfExtensionClassLoader.java:85) - load extension class success, extensionType: interface org.apache.eventmesh.protocol.api.ProtocolAdaptor, extensionClass: class org.apache.eventmesh.protocol.webhook.WebHookProtocolAdaptor 2024-12-17 10:08:47,001 INFO [main] MetaInfExtensionClassLoader(MetaInfExtensionClassLoader.java:85) - load extension class success, extensionType: interface org.apache.eventmesh.protocol.api.ProtocolAdaptor, extensionClass: class org.apache.eventmesh.protocol.cloudevents.CloudEventsProtocolAdaptor 2024-12-17 10:08:47,002 INFO [main] MetaInfExtensionClassLoader(MetaInfExtensionClassLoader.java:85) - load extension class success, extensionType: interface org.apache.eventmesh.protocol.api.ProtocolAdaptor, extensionClass: class org.apache.eventmesh.protocol.openmessage.OpenMessageProtocolAdaptor 2024-12-17 10:08:47,002 INFO [main] EventMeshExtensionFactory(EventMeshExtensionFactory.java:103) - initialize extension instance success, extensionClass: interface org.apache.eventmesh.protocol.api.ProtocolAdaptor, extensionInstanceName: webhook 2024-12-17 10:08:47,003 INFO [main] HandlerService(HandlerService.java:110) - path is /webhook processor name is WebHookProcessor 2024-12-17 10:08:47,003 INFO [main] EventMeshHTTPServer(LogUtils.java:118) - ==================EventMeshHTTPServer initialized================== 2024-12-17 10:08:47,005 INFO [main] EventMeshTCPServer(LogUtils.java:118) - ==================EventMeshTCPServer Initialing================== 2024-12-17 10:08:47,005 INFO [main] ProducerManager(ProducerManager.java:42) - producerManager inited...... 2024-12-17 10:08:47,009 INFO [main] ClientSessionGroupMapping(ClientSessionGroupMapping.java:421) - ClientSessionGroupMapping inited...... 2024-12-17 10:08:47,010 INFO [main] EventMeshTcpMonitor(EventMeshTcpMonitor.java:78) - EventMeshTcpMonitor initialized...... 2024-12-17 10:08:47,012 INFO [main] AdminWebHookConfigOperationManager(LogUtils.java:130) - operationMode is file properties is {filePath=#{eventMeshHome}/webhook} 2024-12-17 10:08:47,016 INFO [main] EventMeshTCPServer(LogUtils.java:118) - --------------------------EventMeshTCPServer Inited 2024-12-17 10:08:47,017 INFO [main] EventMeshGrpcServer(EventMeshGrpcServer.java:105) - ==================EventMeshGRPCServer Initializing================== 2024-12-17 10:08:47,178 INFO [main] ProducerManager(ProducerManager.java:42) - producerManager inited...... 2024-12-17 10:08:47,179 INFO [main] ConsumerManager(LogUtils.java:118) - Grpc ConsumerManager initialized. 2024-12-17 10:08:47,204 DEBUG [main] InternalLoggerFactory(InternalLoggerFactory.java:63) - Using SLF4J as the default logging framework 2024-12-17 10:08:47,206 DEBUG [main] PlatformDependent0(PlatformDependent0.java:433) - -Dio.netty.noUnsafe: false 2024-12-17 10:08:47,206 DEBUG [main] PlatformDependent0(PlatformDependent0.java:927) - Java version: 8 2024-12-17 10:08:47,207 DEBUG [main] PlatformDependent0(PlatformDependent0.java:131) - sun.misc.Unsafe.theUnsafe: available 2024-12-17 10:08:47,207 DEBUG [main] PlatformDependent0(PlatformDependent0.java:155) - sun.misc.Unsafe.copyMemory: available 2024-12-17 10:08:47,208 DEBUG [main] PlatformDependent0(PlatformDependent0.java:193) - java.nio.Buffer.address: available 2024-12-17 10:08:47,208 DEBUG [main] PlatformDependent0(PlatformDependent0.java:258) - direct buffer constructor: available 2024-12-17 10:08:47,209 DEBUG [main] PlatformDependent0(PlatformDependent0.java:332) - java.nio.Bits.unaligned: available, true 2024-12-17 10:08:47,209 DEBUG [main] PlatformDependent0(PlatformDependent0.java:397) - jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable prior to Java9 2024-12-17 10:08:47,209 DEBUG [main] PlatformDependent0(PlatformDependent0.java:419) - java.nio.DirectByteBuffer.<init>(long, int): available 2024-12-17 10:08:47,209 DEBUG [main] PlatformDependent(PlatformDependent.java:1106) - sun.misc.Unsafe: available 2024-12-17 10:08:47,209 DEBUG [main] PlatformDependent(PlatformDependent.java:1227) - -Dio.netty.tmpdir: /tmp (java.io.tmpdir) 2024-12-17 10:08:47,209 DEBUG [main] PlatformDependent(PlatformDependent.java:1306) - -Dio.netty.bitMode: 64 (sun.arch.data.model) 2024-12-17 10:08:47,210 DEBUG [main] PlatformDependent(PlatformDependent.java:178) - -Dio.netty.maxDirectMemory: 3700424704 bytes 2024-12-17 10:08:47,210 DEBUG [main] PlatformDependent(PlatformDependent.java:185) - -Dio.netty.uninitializedArrayAllocationThreshold: -1 2024-12-17 10:08:47,211 DEBUG [main] CleanerJava6(CleanerJava6.java:92) - java.nio.ByteBuffer.cleaner(): available 2024-12-17 10:08:47,211 DEBUG [main] PlatformDependent(PlatformDependent.java:205) - -Dio.netty.noPreferDirect: false 2024-12-17 10:08:47,228 DEBUG [main] NativeLibraryLoader(NativeLibraryLoader.java:73) - -Dio.netty.native.workdir: /tmp (io.netty.tmpdir) 2024-12-17 10:08:47,228 DEBUG [main] NativeLibraryLoader(NativeLibraryLoader.java:78) - -Dio.netty.native.deleteLibAfterLoading: true 2024-12-17 10:08:47,228 DEBUG [main] NativeLibraryLoader(NativeLibraryLoader.java:82) - -Dio.netty.native.tryPatchShadedId: true 2024-12-17 10:08:47,236 DEBUG [main] NativeLibraryLoader(NativeLibraryLoader.java:337) - Successfully loaded the library /tmp/libio_grpc_netty_shaded_netty_transport_native_epoll_x86_645601993010941658959.so 2024-12-17 10:08:47,239 DEBUG [main] NetUtil(NetUtil.java:135) - -Djava.net.preferIPv4Stack: false 2024-12-17 10:08:47,239 DEBUG [main] NetUtil(NetUtil.java:136) - -Djava.net.preferIPv6Addresses: false 2024-12-17 10:08:47,240 DEBUG [main] NetUtilInitializations(NetUtilInitializations.java:129) - Loopback interface: lo (lo, 0:0:0:0:0:0:0:1%lo) 2024-12-17 10:08:47,241 DEBUG [main] NetUtil(NetUtil.java:169) - /proc/sys/net/core/somaxconn: 32768 2024-12-17 10:08:47,257 DEBUG [main] MultithreadEventLoopGroup(MultithreadEventLoopGroup.java:44) - -Dio.netty.eventLoopThreads: 8 2024-12-17 10:08:47,303 DEBUG [main] InternalThreadLocalMap(InternalThreadLocalMap.java:83) - -Dio.netty.threadLocalMap.stringBuilder.initialSize: 1024 2024-12-17 10:08:47,303 DEBUG [main] InternalThreadLocalMap(InternalThreadLocalMap.java:86) - -Dio.netty.threadLocalMap.stringBuilder.maxSize: 4096 2024-12-17 10:08:47,313 DEBUG [main] PlatformDependent(PlatformDependent.java:967) - org.jctools-core.MpscChunkedArrayQueue: available 2024-12-17 10:08:47,322 INFO [main] EventMeshGrpcServer(EventMeshGrpcServer.java:129) - GRPCServer[port=10205] started 2024-12-17 10:08:47,322 INFO [main] EventMeshGrpcServer(EventMeshGrpcServer.java:130) - -----------------EventMeshGRPCServer initialized 2024-12-17 10:08:47,323 INFO [main] EventMeshServer(LogUtils.java:124) - eventStore : null 2024-12-17 10:08:47,324 INFO [main] ProducerTopicManager(ProducerTopicManager.java:52) - ProducerTopicManager inited...... 2024-12-17 10:08:47,324 INFO [main] EventMeshServer(LogUtils.java:124) - server state:INITED 2024-12-17 10:08:47,339 INFO [EventMesh-http-server] AbstractHTTPServer(LogUtils.java:124) - HTTPServer[port=10105] started. 2024-12-17 10:08:47,343 INFO [main] HTTPMetricsServer(LogUtils.java:124) - Register httpMetrics to org.apache.eventmesh.metrics.prometheus.PrometheusMetricsRegistry 2024-12-17 10:08:47,344 INFO [main] HTTPMetricsServer(LogUtils.java:118) - HTTPMetricsServer started. 2024-12-17 10:08:47,344 INFO [main] ConsumerManager(ConsumerManager.java:54) - consumerManager started...... 2024-12-17 10:08:47,344 INFO [main] ProducerManager(ProducerManager.java:46) - producerManager started...... 2024-12-17 10:08:47,344 DEBUG [EventMesh-http-server] DefaultChannelId(DefaultChannelId.java:79) - -Dio.netty.processId: 23386 (auto-detected) 2024-12-17 10:08:47,347 INFO [main] AbstractRetryer(AbstractRetryer.java:57) - EventMesh retryer started...... 2024-12-17 10:08:47,347 INFO [main] EventMeshHTTPServer(LogUtils.java:118) - ==================EventMeshHTTPServer started================== 2024-12-17 10:08:47,355 INFO [main] EventMeshTcpMonitor(EventMeshTcpMonitor.java:84) - Register tcpMetrics to org.apache.eventmesh.metrics.prometheus.PrometheusMetricsRegistry 2024-12-17 10:08:47,356 DEBUG [EventMesh-http-server] DefaultChannelId(DefaultChannelId.java:101) - -Dio.netty.machineId: 50:9a:4c:ff:fe:16:d8:86 (auto-detected) 2024-12-17 10:08:47,358 INFO [main] EventMeshTcpMonitor(EventMeshTcpMonitor.java:150) - EventMeshTcpMonitor started...... 2024-12-17 10:08:47,358 INFO [main] ClientSessionGroupMapping(ClientSessionGroupMapping.java:425) - ClientSessionGroupMapping started...... 2024-12-17 10:08:47,358 INFO [main] AbstractRetryer(AbstractRetryer.java:57) - EventMesh retryer started...... 2024-12-17 10:08:47,358 INFO [main] EventMeshTCPServer(LogUtils.java:118) - --------------------------EventMeshTCPServer Started 2024-12-17 10:08:47,358 INFO [main] EventMeshGrpcServer(EventMeshGrpcServer.java:139) - ---------------EventMeshGRPCServer starting------------------- 2024-12-17 10:08:47,358 INFO [main] ProducerManager(ProducerManager.java:46) - producerManager started...... 2024-12-17 10:08:47,359 INFO [main] ConsumerManager(LogUtils.java:118) - Grpc ConsumerManager started. 2024-12-17 10:08:47,359 INFO [main] AbstractRetryer(AbstractRetryer.java:57) - EventMesh retryer started...... 2024-12-17 10:08:47,371 DEBUG [EventMesh-http-server] ResourceLeakDetector(ResourceLeakDetector.java:129) - -Dio.netty.leakDetection.level: simple 2024-12-17 10:08:47,371 DEBUG [EventMesh-http-server] ResourceLeakDetector(ResourceLeakDetector.java:130) - -Dio.netty.leakDetection.targetRecords: 4 2024-12-17 10:08:47,377 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:157) - -Dio.netty.allocator.numHeapArenas: 8 2024-12-17 10:08:47,377 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:158) - -Dio.netty.allocator.numDirectArenas: 8 2024-12-17 10:08:47,377 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:160) - -Dio.netty.allocator.pageSize: 8192 2024-12-17 10:08:47,377 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:165) - -Dio.netty.allocator.maxOrder: 9 2024-12-17 10:08:47,377 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:169) - -Dio.netty.allocator.chunkSize: 4194304 2024-12-17 10:08:47,377 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:170) - -Dio.netty.allocator.smallCacheSize: 256 2024-12-17 10:08:47,377 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:171) - -Dio.netty.allocator.normalCacheSize: 64 2024-12-17 10:08:47,377 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:172) - -Dio.netty.allocator.maxCachedBufferCapacity: 32768 2024-12-17 10:08:47,377 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:173) - -Dio.netty.allocator.cacheTrimInterval: 8192 2024-12-17 10:08:47,378 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:174) - -Dio.netty.allocator.cacheTrimIntervalMillis: 0 2024-12-17 10:08:47,378 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:175) - -Dio.netty.allocator.useCacheForAllThreads: false 2024-12-17 10:08:47,378 DEBUG [eventMesh-tcp-server] PooledByteBufAllocator(PooledByteBufAllocator.java:176) - -Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023 2024-12-17 10:08:47,388 DEBUG [EventMesh-http-server] ByteBufUtil(ByteBufUtil.java:87) - -Dio.netty.allocator.type: pooled 2024-12-17 10:08:47,388 DEBUG [EventMesh-http-server] ByteBufUtil(ByteBufUtil.java:96) - -Dio.netty.threadLocalDirectBufferSize: 0 2024-12-17 10:08:47,388 DEBUG [EventMesh-http-server] ByteBufUtil(ByteBufUtil.java:99) - -Dio.netty.maxThreadLocalCharBufferSize: 16384 2024-12-17 10:08:47,389 DEBUG [main] ResourceLeakDetector(ResourceLeakDetector.java:129) - -Dio.grpc.netty.shaded.io.netty.leakDetection.level: simple 2024-12-17 10:08:47,389 DEBUG [main] ResourceLeakDetector(ResourceLeakDetector.java:130) - -Dio.grpc.netty.shaded.io.netty.leakDetection.targetRecords: 4 2024-12-17 10:08:47,389 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:155) - -Dio.netty.allocator.numHeapArenas: 8 2024-12-17 10:08:47,389 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:156) - -Dio.netty.allocator.numDirectArenas: 8 2024-12-17 10:08:47,389 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:158) - -Dio.netty.allocator.pageSize: 8192 2024-12-17 10:08:47,390 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:163) - -Dio.netty.allocator.maxOrder: 11 2024-12-17 10:08:47,390 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:167) - -Dio.netty.allocator.chunkSize: 16777216 2024-12-17 10:08:47,390 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:168) - -Dio.netty.allocator.smallCacheSize: 256 2024-12-17 10:08:47,390 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:169) - -Dio.netty.allocator.normalCacheSize: 64 2024-12-17 10:08:47,390 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:170) - -Dio.netty.allocator.maxCachedBufferCapacity: 32768 2024-12-17 10:08:47,390 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:171) - -Dio.netty.allocator.cacheTrimInterval: 8192 2024-12-17 10:08:47,390 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:172) - -Dio.netty.allocator.cacheTrimIntervalMillis: 0 2024-12-17 10:08:47,390 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:173) - -Dio.netty.allocator.useCacheForAllThreads: true 2024-12-17 10:08:47,390 DEBUG [main] PooledByteBufAllocator(PooledByteBufAllocator.java:174) - -Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023 2024-12-17 10:08:47,406 INFO [eventMesh-tcp-server] AbstractTCPServer(AbstractTCPServer.java:146) - EventMeshTCPServer[port=10000] started..... 2024-12-17 10:08:47,410 DEBUG [grpc-default-boss-ELG-1-1] DefaultChannelId(DefaultChannelId.java:79) - -Dio.netty.processId: 23386 (auto-detected) 2024-12-17 10:08:47,412 DEBUG [grpc-default-boss-ELG-1-1] DefaultChannelId(DefaultChannelId.java:101) - -Dio.netty.machineId: 50:9a:4c:ff:fe:16:d8:86 (auto-detected) 2024-12-17 10:08:47,428 DEBUG [grpc-default-boss-ELG-1-1] ByteBufUtil(ByteBufUtil.java:87) - -Dio.netty.allocator.type: pooled 2024-12-17 10:08:47,428 DEBUG [grpc-default-boss-ELG-1-1] ByteBufUtil(ByteBufUtil.java:96) - -Dio.netty.threadLocalDirectBufferSize: 0 2024-12-17 10:08:47,428 DEBUG [grpc-default-boss-ELG-1-1] ByteBufUtil(ByteBufUtil.java:99) - -Dio.netty.maxThreadLocalCharBufferSize: 16384 2024-12-17 10:08:47,440 INFO [main] EventMeshGrpcServer(EventMeshGrpcServer.java:151) - ---------------EventMeshGRPCServer running------------------- 2024-12-17 10:08:47,462 INFO [main] MetaInfExtensionClassLoader(MetaInfExtensionClassLoader.java:85) - load extension class success, extensionType: interface org.apache.eventmesh.api.admin.Admin, extensionClass: class org.apache.eventmesh.storage.rocketmq.admin.RocketMQAdminAdaptor 2024-12-17 10:08:47,463 INFO [main] MetaInfExtensionClassLoader(MetaInfExtensionClassLoader.java:85) - load extension class success, extensionType: interface org.apache.eventmesh.api.admin.Admin, extensionClass: class org.apache.eventmesh.storage.standalone.admin.StandaloneAdminAdaptor 2024-12-17 10:08:47,482 INFO [main] EventMeshExtensionFactory(EventMeshExtensionFactory.java:133) - initialize extension instance success, extensionType: interface org.apache.eventmesh.api.admin.Admin, extensionName: rocketmq 2024-12-17 10:08:47,485 INFO [main] EventMeshExtensionFactory(EventMeshExtensionFactory.java:133) - initialize extension instance success, extensionType: interface org.apache.eventmesh.api.admin.Admin, extensionName: rocketmq 2024-12-17 10:08:47,490 INFO [main] ClientManageController(ClientManageController.java:122) - ClientManageController start success, port:10106 2024-12-17 10:08:47,491 INFO [main] ProducerTopicManager(ProducerTopicManager.java:74) - ProducerTopicManager started...... 2024-12-17 10:08:47,491 INFO [main] EventMeshServer(LogUtils.java:124) - server state:RUNNING 2024-12-17 10:08:48,344 INFO [eventMesh-metrics-1] HTTPMetricsServer(LogUtils.java:118) - ===========================================SERVER METRICS================================================== 2024-12-17 10:08:48,348 INFO [eventMesh-metrics-1] HTTPMetricsServer(LogUtils.java:136) - maxHTTPTPS: 0.0, avgHTTPTPS: 0.0, maxHTTPCOST: 0, avgHTTPCOST: 0.0, avgHTTPBodyDecodeCost: 0.0, httpDiscard: 0 2024-12-17 10:08:48,348 INFO [eventMesh-metrics-1] HTTPMetricsServer(LogUtils.java:136) - maxBatchSendMsgTPS: 0.0, avgBatchSendMsgTPS: 0.0, sum: 0. sumFail: 0, sumFailRate: 0.0, discard : 0 2024-12-17 10:08:48,349 INFO [eventMesh-metrics-1] HTTPMetricsServer(LogUtils.java:136) - maxSendMsgTPS: 0.0, avgSendMsgTPS: 0.0, sum: 0, sumFail: 0, sumFailRate: 0.0, replyMsg: 0, replyFail: 0 2024-12-17 10:08:48,349 INFO [eventMesh-metrics-1] HTTPMetricsServer(LogUtils.java:136) - maxPushMsgTPS: 0.0, avgPushMsgTPS: 0.0, sum: 0, sumFail: 0, sumFailRate: 0.0, maxClientLatency: 0.0, avgClientLatency: 0.0 2024-12-17 10:08:48,349 INFO [eventMesh-metrics-1] HTTPMetricsServer(LogUtils.java:136) - batchMsgQ: 0, sendMsgQ: 0, pushMsgQ: 0, httpRetryQ: 0 2024-12-17 10:08:48,350 INFO [eventMesh-metrics-1] HTTPMetricsServer(LogUtils.java:136) - batchAvgSend2MQCost: 0.0, avgSend2MQCost: 0.0, avgReply2MQCost: 0.0 ``` -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
