apache / eventmesh
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 1,663 files with 124,927 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 29 files changed 51-100 times (6,599 lines of code)
    • 102 files changed 21-50 times (9,150 lines of code)
    • 274 files changed 6-20 times (18,466 lines of code)
    • 1,258 files changed 1-5 times (90,712 lines of code)
0% | 5% | 7% | 14% | 72%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 1,663 files with 124,927 lines of code.
    • 42 files changed by more than 25 contributors (8,405 lines of code)
    • 196 files changed by 11-25 contributors (12,486 lines of code)
    • 131 files changed by 6-10 contributors (8,591 lines of code)
    • 482 files changed by 2-5 contributors (30,929 lines of code)
    • 812 files changed by 1 contributor (64,516 lines of code)
6% | 9% | 6% | 24% | 51%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, yaml, go, properties, gradle, txt, rs, sh, h, xml, c, md, proto, gitignore, mod, dockerignore, html, g4, bat, gitmodules, gitattributes, sql, toml, php
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 8% | 11% | 22% | 58%
xml0% | 0% | 0% | 42% | 57%
sql0% | 0% | 0% | 100% | 0%
toml0% | 0% | 0% | 100% | 0%
c0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
go0% | 0% | 0% | 0% | 100%
g40% | 0% | 0% | 0% | 100%
h0% | 0% | 0% | 0% | 100%
rs0% | 0% | 0% | 0% | 100%
proto0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
eventmesh-runtime0% | 31% | 25% | 16% | 25%
eventmesh-common0% | 1% | 11% | 34% | 52%
eventmesh-examples0% | 0% | 69% | 23% | 6%
eventmesh-protocol-plugin0% | 0% | 46% | 24% | 28%
eventmesh-trace-plugin0% | 0% | 73% | 10% | 15%
eventmesh-openconnect0% | 0% | 14% | 37% | 47%
eventmesh-spi0% | 0% | 60% | 28% | 10%
eventmesh-security-plugin0% | 0% | 10% | 89% | 0%
eventmesh-connectors0% | 0% | 0% | 15% | 84%
eventmesh-sdks0% | 0% | 0% | 4% | 95%
eventmesh-storage-plugin0% | 0% | 0% | 20% | 79%
eventmesh-meta0% | 0% | 0% | 31% | 68%
eventmesh-admin-server0% | 0% | 0% | 13% | 86%
eventmesh-runtime-v20% | 0% | 0% | 25% | 74%
style0% | 0% | 0% | 52% | 47%
eventmesh-metrics-plugin0% | 0% | 0% | 10% | 89%
eventmesh-starter0% | 0% | 0% | 100% | 0%
eventmesh-operator0% | 0% | 0% | 0% | 100%
eventmesh-function0% | 0% | 0% | 0% | 100%
eventmesh-retry0% | 0% | 0% | 0% | 100%
tools0% | 0% | 0% | 0% | 100%
eventmesh-registry0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
EventMeshHTTPServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 196 7 2021-04-20 2025-01-07 92 41 gcslyp@gmail.com xiatian@apache.org
ClientGroupWrapper.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group
 619 36 2021-04-20 2024-04-19 88 47 gcslyp@gmail.com ljbmxsm@gmail.com
AbstractHTTPServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 406 22 2021-07-16 2025-03-18 84 40 liudw@apache.org mike_xwm@126.com
EventMeshServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 177 5 2021-04-20 2024-06-02 83 41 gcslyp@gmail.com xiatian@apache.org
EventMeshTCPServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 188 17 2021-04-20 2025-01-07 82 40 gcslyp@gmail.com xiatian@apache.org
CommonConfiguration.java
in eventmesh-common/src/main/java/org/apache/eventmesh/common/config
 78 1 2021-04-19 2025-01-07 80 37 397294722@qq.com xiatian@apache.org
AsyncHTTPPushRequest.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push
 309 9 2021-04-20 2025-01-07 78 36 gcslyp@gmail.com xiatian@apache.org
SendAsyncMessageProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 247 4 2021-04-20 2024-04-19 76 40 gcslyp@gmail.com ljbmxsm@gmail.com
EventMeshConsumer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer
 270 12 2021-04-20 2024-01-12 76 41 gcslyp@gmail.com xiatian@apache.org
SendAsyncEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 241 3 2022-06-15 2024-10-28 73 40 mike_xwm@126.com cnzakii@gmail.com
ReplyMessageProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 199 3 2021-04-20 2024-05-06 68 39 gcslyp@gmail.com 91261012+cnzakii@users.nore...
SendSyncMessageProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 222 3 2021-04-20 2024-04-24 68 35 gcslyp@gmail.com 151615370+rohit-satya@users...
ClientSessionGroupMapping.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group
 430 30 2021-04-20 2024-01-12 68 33 gcslyp@gmail.com xiatian@apache.org
SendAsyncRemoteEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 250 4 2022-06-15 2024-04-19 67 33 mike_xwm@126.com ljbmxsm@gmail.com
BatchSendMessageProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 219 3 2021-04-20 2024-04-19 65 40 gcslyp@gmail.com ljbmxsm@gmail.com
EventMeshUtil.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util
 229 17 2021-04-20 2024-01-12 64 35 gcslyp@gmail.com xiatian@apache.org
RemoteSubscribeEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 137 3 2022-06-15 2025-01-07 63 35 mike_xwm@126.com xiatian@apache.org
SubscribeProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 154 4 2021-04-20 2025-01-07 63 36 gcslyp@gmail.com xiatian@apache.org
LocalSubscribeEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 139 4 2022-06-15 2025-01-07 62 35 mike_xwm@126.com xiatian@apache.org
LocalUnSubscribeEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 203 4 2022-06-15 2024-02-18 62 36 mike_xwm@126.com karsontao@hotmail.com
BatchSendMessageV2Processor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 202 3 2021-04-20 2024-04-19 61 36 gcslyp@gmail.com ljbmxsm@gmail.com
RemoteUnSubscribeEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 134 3 2022-06-15 2024-02-18 60 36 mike_xwm@126.com karsontao@hotmail.com
SessionPusher.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push
 132 8 2021-04-20 2025-03-18 58 36 gcslyp@gmail.com mike_xwm@126.com
Session.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session
 226 14 2021-04-20 2024-04-19 58 35 gcslyp@gmail.com ljbmxsm@gmail.com
Constants.java
in eventmesh-common/src/main/java/org/apache/eventmesh/common
 95 - 2021-04-19 2024-06-02 55 33 397294722@qq.com xiatian@apache.org
SessionSender.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send
 170 6 2021-04-20 2024-04-19 54 32 gcslyp@gmail.com ljbmxsm@gmail.com
UnSubscribeProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 201 4 2021-04-20 2024-04-19 53 31 gcslyp@gmail.com ljbmxsm@gmail.com
HandlerService.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 298 19 2022-06-19 2025-03-18 52 30 2372554140@qq.com mike_xwm@126.com
EventMeshGrpcServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 228 23 2022-02-21 2024-04-19 51 27 mike_xwm@126.com ljbmxsm@gmail.com
EventMeshConsumer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer
 285 13 2022-02-21 2024-04-19 48 27 mike_xwm@126.com ljbmxsm@gmail.com
HeartBeatProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 161 4 2021-04-20 2024-04-19 47 33 gcslyp@gmail.com ljbmxsm@gmail.com
EventMeshConstants.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/constants
 104 - 2021-04-20 2024-04-15 46 32 gcslyp@gmail.com xiatian@apache.org
EventMeshStartup.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 34 1 2021-04-20 2024-01-12 44 24 gcslyp@gmail.com xiatian@apache.org
EventMeshHTTPConfiguration.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration
 76 - 2021-04-20 2025-01-07 44 26 gcslyp@gmail.com xiatian@apache.org
EventMeshTestUtils.java
in eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common
 135 17 2021-09-09 2023-10-20 44 31 qqeasonchen@gmail.com 70262922+vishalmcf@users.no...
AbstractEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/inf
 144 7 2022-06-21 2023-10-20 44 24 644968328@qq.com 70262922+vishalmcf@users.no...
Codec.java
in eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/codec
 178 8 2021-04-19 2024-04-04 44 28 397294722@qq.com xiatian@apache.org
ConsumerManager.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer
 185 12 2022-02-21 2024-01-12 44 26 mike_xwm@126.com xiatian@apache.org
HTTPMessageHandler.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push
 68 3 2021-04-20 2023-11-07 43 25 gcslyp@gmail.com bruceyan@didiglobal.com
Utils.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util
 99 6 2021-04-20 2025-03-18 43 29 gcslyp@gmail.com mike_xwm@126.com
ConsumerManager.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer
 149 13 2021-04-20 2023-09-30 43 31 gcslyp@gmail.com bruceyan@didiglobal.com
DownStreamMsgContext.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push
 149 8 2021-04-20 2023-11-14 40 27 gcslyp@gmail.com bruceyan@didiglobal.com
ZipkinTraceService.java
in eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/java/org/apache/eventmesh/trace/zipkin
 69 3 2022-02-24 2023-09-30 39 24 84842773+roc-00@users.norep... bruceyan@didiglobal.com
SubService.java
in eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/app/service
 86 3 2022-02-21 2024-01-12 39 28 mike_xwm@126.com xiatian@apache.org
IPUtils.java
in eventmesh-common/src/main/java/org/apache/eventmesh/common/utils
 181 9 2021-11-21 2024-05-31 39 25 wenjun@apache.org mike_xwm@126.com
AbstractRemotingServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 80 8 2021-04-20 2025-03-18 38 27 gcslyp@gmail.com mike_xwm@126.com
EventMeshTCPConfiguration.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration
 87 - 2021-04-20 2024-06-02 38 25 gcslyp@gmail.com xiatian@apache.org
MeshMessageProtocolAdaptor.java
in eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage
 113 7 2021-11-19 2023-10-07 38 24 mike_xwm@126.com ljbmxsm@gmail.com
UpStreamMsgContext.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send
 119 9 2021-04-20 2023-11-14 38 26 gcslyp@gmail.com bruceyan@didiglobal.com
CloudEventsProtocolAdaptor.java
in eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents
 116 6 2021-10-28 2023-09-30 37 23 wenjun@apache.org bruceyan@didiglobal.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ClientGroupWrapper.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group
 619 36 2021-04-20 2024-04-19 88 47 gcslyp@gmail.com ljbmxsm@gmail.com
EventMeshHTTPServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 196 7 2021-04-20 2025-01-07 92 41 gcslyp@gmail.com xiatian@apache.org
EventMeshServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 177 5 2021-04-20 2024-06-02 83 41 gcslyp@gmail.com xiatian@apache.org
EventMeshConsumer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer
 270 12 2021-04-20 2024-01-12 76 41 gcslyp@gmail.com xiatian@apache.org
AbstractHTTPServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 406 22 2021-07-16 2025-03-18 84 40 liudw@apache.org mike_xwm@126.com
EventMeshTCPServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 188 17 2021-04-20 2025-01-07 82 40 gcslyp@gmail.com xiatian@apache.org
SendAsyncMessageProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 247 4 2021-04-20 2024-04-19 76 40 gcslyp@gmail.com ljbmxsm@gmail.com
SendAsyncEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 241 3 2022-06-15 2024-10-28 73 40 mike_xwm@126.com cnzakii@gmail.com
BatchSendMessageProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 219 3 2021-04-20 2024-04-19 65 40 gcslyp@gmail.com ljbmxsm@gmail.com
ReplyMessageProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 199 3 2021-04-20 2024-05-06 68 39 gcslyp@gmail.com 91261012+cnzakii@users.nore...
CommonConfiguration.java
in eventmesh-common/src/main/java/org/apache/eventmesh/common/config
 78 1 2021-04-19 2025-01-07 80 37 397294722@qq.com xiatian@apache.org
AsyncHTTPPushRequest.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push
 309 9 2021-04-20 2025-01-07 78 36 gcslyp@gmail.com xiatian@apache.org
SubscribeProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 154 4 2021-04-20 2025-01-07 63 36 gcslyp@gmail.com xiatian@apache.org
LocalUnSubscribeEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 203 4 2022-06-15 2024-02-18 62 36 mike_xwm@126.com karsontao@hotmail.com
BatchSendMessageV2Processor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 202 3 2021-04-20 2024-04-19 61 36 gcslyp@gmail.com ljbmxsm@gmail.com
RemoteUnSubscribeEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 134 3 2022-06-15 2024-02-18 60 36 mike_xwm@126.com karsontao@hotmail.com
SessionPusher.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push
 132 8 2021-04-20 2025-03-18 58 36 gcslyp@gmail.com mike_xwm@126.com
SendSyncMessageProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 222 3 2021-04-20 2024-04-24 68 35 gcslyp@gmail.com 151615370+rohit-satya@users...
EventMeshUtil.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util
 229 17 2021-04-20 2024-01-12 64 35 gcslyp@gmail.com xiatian@apache.org
RemoteSubscribeEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 137 3 2022-06-15 2025-01-07 63 35 mike_xwm@126.com xiatian@apache.org
LocalSubscribeEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 139 4 2022-06-15 2025-01-07 62 35 mike_xwm@126.com xiatian@apache.org
Session.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session
 226 14 2021-04-20 2024-04-19 58 35 gcslyp@gmail.com ljbmxsm@gmail.com
ClientSessionGroupMapping.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group
 430 30 2021-04-20 2024-01-12 68 33 gcslyp@gmail.com xiatian@apache.org
SendAsyncRemoteEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 250 4 2022-06-15 2024-04-19 67 33 mike_xwm@126.com ljbmxsm@gmail.com
Constants.java
in eventmesh-common/src/main/java/org/apache/eventmesh/common
 95 - 2021-04-19 2024-06-02 55 33 397294722@qq.com xiatian@apache.org
HeartBeatProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 161 4 2021-04-20 2024-04-19 47 33 gcslyp@gmail.com ljbmxsm@gmail.com
SessionSender.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send
 170 6 2021-04-20 2024-04-19 54 32 gcslyp@gmail.com ljbmxsm@gmail.com
EventMeshConstants.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/constants
 104 - 2021-04-20 2024-04-15 46 32 gcslyp@gmail.com xiatian@apache.org
UnSubscribeProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 201 4 2021-04-20 2024-04-19 53 31 gcslyp@gmail.com ljbmxsm@gmail.com
EventMeshTestUtils.java
in eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common
 135 17 2021-09-09 2023-10-20 44 31 qqeasonchen@gmail.com 70262922+vishalmcf@users.no...
ConsumerManager.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer
 149 13 2021-04-20 2023-09-30 43 31 gcslyp@gmail.com bruceyan@didiglobal.com
HandlerService.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor
 298 19 2022-06-19 2025-03-18 52 30 2372554140@qq.com mike_xwm@126.com
Utils.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util
 99 6 2021-04-20 2025-03-18 43 29 gcslyp@gmail.com mike_xwm@126.com
Codec.java
in eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/codec
 178 8 2021-04-19 2024-04-04 44 28 397294722@qq.com xiatian@apache.org
SubService.java
in eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/app/service
 86 3 2022-02-21 2024-01-12 39 28 mike_xwm@126.com xiatian@apache.org
EventMeshGrpcServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 228 23 2022-02-21 2024-04-19 51 27 mike_xwm@126.com ljbmxsm@gmail.com
EventMeshConsumer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer
 285 13 2022-02-21 2024-04-19 48 27 mike_xwm@126.com ljbmxsm@gmail.com
DownStreamMsgContext.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push
 149 8 2021-04-20 2023-11-14 40 27 gcslyp@gmail.com bruceyan@didiglobal.com
AbstractRemotingServer.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 80 8 2021-04-20 2025-03-18 38 27 gcslyp@gmail.com mike_xwm@126.com
ConsumerManager.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer
 185 12 2022-02-21 2024-01-12 44 26 mike_xwm@126.com xiatian@apache.org
EventMeshHTTPConfiguration.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration
 76 - 2021-04-20 2025-01-07 44 26 gcslyp@gmail.com xiatian@apache.org
UpStreamMsgContext.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send
 119 9 2021-04-20 2023-11-14 38 26 gcslyp@gmail.com bruceyan@didiglobal.com
HTTPMessageHandler.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push
 68 3 2021-04-20 2023-11-07 43 25 gcslyp@gmail.com bruceyan@didiglobal.com
IPUtils.java
in eventmesh-common/src/main/java/org/apache/eventmesh/common/utils
 181 9 2021-11-21 2024-05-31 39 25 wenjun@apache.org mike_xwm@126.com
EventMeshTCPConfiguration.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration
 87 - 2021-04-20 2024-06-02 38 25 gcslyp@gmail.com xiatian@apache.org
EventMeshStartup.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot
 34 1 2021-04-20 2024-01-12 44 24 gcslyp@gmail.com xiatian@apache.org
AbstractEventProcessor.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/inf
 144 7 2022-06-21 2023-10-20 44 24 644968328@qq.com 70262922+vishalmcf@users.no...
ZipkinTraceService.java
in eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/java/org/apache/eventmesh/trace/zipkin
 69 3 2022-02-24 2023-09-30 39 24 84842773+roc-00@users.norep... bruceyan@didiglobal.com
MeshMessageProtocolAdaptor.java
in eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage
 113 7 2021-11-19 2023-10-07 38 24 mike_xwm@126.com ljbmxsm@gmail.com
WebhookPushRequest.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push
 201 7 2022-02-21 2023-09-30 37 24 mike_xwm@126.com bruceyan@didiglobal.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
eventmesh-operator.eventmesh_runtimes.yaml
in eventmesh-operator/config/crd/bases
 8057 - 2023-12-05 2023-12-05 1 1 91315508+alonexc@users.nore... 91315508+alonexc@users.nore...
wemq_thread.c
in eventmesh-sdks/eventmesh-sdk-c/src
 4790 65 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
eventmesh-operator.eventmesh_connectors.yaml
in eventmesh-operator/config/crd/bases
 4036 - 2023-12-05 2024-01-18 2 1 91315508+alonexc@users.nore... 91315508+alonexc@users.nore...
MySqlParser.g4
in eventmesh-connectors/eventmesh-connector-jdbc/src/main/antlr
 2411 - 2023-09-13 2023-09-13 1 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
rmb_pub.c
in eventmesh-sdks/eventmesh-sdk-c/src
 1946 27 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
rmb_msg.c
in eventmesh-sdks/eventmesh-sdk-c/src
 1386 28 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
eventmesh-client.pb.go
in eventmesh-sdks/eventmesh-sdk-go/grpc/proto
 1271 128 2023-05-22 2023-05-22 1 1 mike_xwm@126.com mike_xwm@126.com
MySqlLexer.g4
in eventmesh-connectors/eventmesh-connector-jdbc/src/main/antlr
 1262 - 2023-09-13 2023-09-13 1 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
rmb_mq.c
in eventmesh-sdks/eventmesh-sdk-c/src
 1092 32 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
rmb_sub.c
in eventmesh-sdks/eventmesh-sdk-c/src
 1040 39 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
rmb_log.c
in eventmesh-sdks/eventmesh-sdk-c/src
 990 23 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
rmb_define.h
in eventmesh-sdks/eventmesh-sdk-c/include
 833 - 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
rmb_context.c
in eventmesh-sdks/eventmesh-sdk-c/src
 751 15 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
CanalSinkIncrementConnector.java
in eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector
 740 27 2024-08-21 2024-12-09 2 1 mike_xwm@126.com mike_xwm@126.com
Metadata.java
in eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver
 732 66 2024-05-31 2024-05-31 1 1 mike_xwm@126.com mike_xwm@126.com
rmb_access_config.c
in eventmesh-sdks/eventmesh-sdk-c/src
 667 16 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
Payload.java
in eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver
 667 65 2024-05-31 2024-05-31 1 1 mike_xwm@126.com mike_xwm@126.com
wemq_tcp.c
in eventmesh-sdks/eventmesh-sdk-c/src
 630 9 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
wemq_proto.c
in eventmesh-sdks/eventmesh-sdk-c/src
 618 69 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
HttpMetrics.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http
 589 64 2024-04-19 2024-04-19 1 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
CanalCheckConsumer.java
in eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector
 491 14 2024-12-09 2024-12-09 1 1 mike_xwm@126.com mike_xwm@126.com
CanalSourceIncrementConnector.java
in eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/connector
 369 14 2024-08-21 2024-12-09 2 1 mike_xwm@126.com mike_xwm@126.com
wemq_proto.h
in eventmesh-sdks/eventmesh-sdk-c/include
 365 - 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
eventmesh-client_grpc.pb.go
in eventmesh-sdks/eventmesh-sdk-go/grpc/proto
 355 34 2023-05-22 2023-05-22 1 1 mike_xwm@126.com mike_xwm@126.com
CanalFullConsumer.java
in eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector
 353 7 2024-12-09 2024-12-09 1 1 mike_xwm@126.com mike_xwm@126.com
wemq_fifo.h
in eventmesh-sdks/eventmesh-sdk-c/include
 341 6 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
RaftMetaService.java
in eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft
 334 17 2024-05-30 2024-05-30 1 1 karsontao@hotmail.com karsontao@hotmail.com
message_log_api.c
in eventmesh-sdks/eventmesh-sdk-c/src
 328 4 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
rmb_udp.c
in eventmesh-sdks/eventmesh-sdk-c/src
 286 9 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
NacosDiscoveryService.java
in eventmesh-registry/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos
 271 8 2024-05-31 2024-05-31 1 1 mike_xwm@126.com mike_xwm@126.com
AdminServiceGrpc.java
in eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver
 267 14 2024-05-31 2024-05-31 1 1 mike_xwm@126.com mike_xwm@126.com
consumer.go
in eventmesh-sdks/eventmesh-sdk-go/grpc
 245 9 2023-05-22 2023-05-22 1 1 mike_xwm@126.com mike_xwm@126.com
subscription.rs
in eventmesh-sdks/eventmesh-sdk-rust/src/model
 233 13 2023-10-17 2023-12-08 2 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
rmb_list.h
in eventmesh-sdks/eventmesh-sdk-c/include
 229 22 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
lib.rs
in eventmesh-sdks/eventmesh-sdk-rust/src
 224 5 2023-10-17 2023-11-02 2 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
zz_generated.deepcopy.go
in eventmesh-operator/api/v1
 212 20 2023-12-05 2023-12-05 1 1 91315508+alonexc@users.nore... 91315508+alonexc@users.nore...
GeneralDialectAssemblyLine.java
in eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/handle
 211 14 2024-02-18 2024-02-18 1 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
DbLoadMerger.java
in eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink
 211 10 2024-05-31 2024-05-31 1 1 mike_xwm@126.com mike_xwm@126.com
RSAUtils.java
in eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/utils
 209 6 2024-12-11 2024-12-11 1 1 mike_xwm@126.com mike_xwm@126.com
CanalCheckPositionMgr.java
in eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/position
 208 13 2024-12-09 2024-12-09 1 1 mike_xwm@126.com mike_xwm@126.com
wemq_fifo.c
in eventmesh-sdks/eventmesh-sdk-c/src
 206 18 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
wemq_topic_list.c
in eventmesh-sdks/eventmesh-sdk-c/src
 203 8 2023-11-01 2023-11-01 1 1 rainzrq@qq.com rainzrq@qq.com
grpc_client.rs
in eventmesh-sdks/eventmesh-sdk-rust/src/net/grpc
 197 - 2023-10-17 2023-10-17 1 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
TcpMetrics.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/tcp
 195 27 2024-04-19 2024-04-19 1 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
PrometheusMetricsRegistryManager.java
in eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus
 194 6 2024-04-19 2024-04-19 1 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
fake_grpcserver.go
in eventmesh-sdks/eventmesh-sdk-go/grpc
 186 8 2023-05-22 2023-05-22 1 1 mike_xwm@126.com mike_xwm@126.com
EventMeshHttpMetricsManager.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http
 185 13 2024-04-19 2024-04-19 1 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
GrpcMetrics.java
in eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/grpc
 184 20 2024-04-19 2024-04-19 1 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
message.rs
in eventmesh-sdks/eventmesh-sdk-rust/src/model
 181 8 2023-10-17 2023-12-08 3 1 ljbmxsm@gmail.com ljbmxsm@gmail.com
CanalConnectRecord.java
in eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal
 177 8 2024-05-31 2024-08-07 3 1 mike_xwm@126.com mike_xwm@126.com
Correlations

File Size vs. Number of Changes: 1667 points

eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/AbstractHttpHandler.java x: 107 lines of code y: 11 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java x: 406 lines of code y: 84 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractRemotingServer.java x: 80 lines of code y: 38 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractTCPServer.java x: 391 lines of code y: 11 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshAdminServer.java x: 144 lines of code y: 5 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HandlerService.java x: 298 lines of code y: 52 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/EventMeshTcp2Client.java x: 112 lines of code y: 28 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/processor/HelloProcessor.java x: 91 lines of code y: 6 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/processor/MessageTransferProcessor.java x: 225 lines of code y: 4 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/SessionPusher.java x: 132 lines of code y: 58 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/Utils.java x: 99 lines of code y: 43 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java x: 56 lines of code y: 5 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatRequestHeader.java x: 35 lines of code y: 22 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeader.java x: 35 lines of code y: 17 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/CommonConfiguration.java x: 78 lines of code y: 80 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/AdminHandlerManager.java x: 77 lines of code y: 6 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/v1/ConfigurationHandlerV1.java x: 47 lines of code y: 2 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshHTTPServer.java x: 196 lines of code y: 92 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshTCPServer.java x: 188 lines of code y: 82 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshHTTPConfiguration.java x: 76 lines of code y: 44 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalSubscribeEventProcessor.java x: 139 lines of code y: 62 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteSubscribeEventProcessor.java x: 137 lines of code y: 63 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SubscribeProcessor.java x: 154 lines of code y: 63 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/AsyncHTTPPushRequest.java x: 309 lines of code y: 78 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/ExampleAdminServer.java x: 16 lines of code y: 5 # changes tools/dist-license/licenses/java/AL 2.0-downloaded-LICENSE-2.0.html x: 485 lines of code y: 2 # changes eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/MetaStateMachine.java x: 149 lines of code y: 2 # changes eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/serialize/EventMeshHessianSerializer.java x: 51 lines of code y: 1 # changes eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/serialize/EventMeshSerializerFactory.java x: 112 lines of code y: 1 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/http/SinkConnectorConfig.java x: 26 lines of code y: 2 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/http/SourceConnectorConfig.java x: 17 lines of code y: 6 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/common/SynchronizedCircularFifoQueue.java x: 89 lines of code y: 4 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/HttpSinkConnector.java x: 131 lines of code y: 7 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/data/HttpExportMetadata.java x: 17 lines of code y: 3 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/HttpDeliveryStrategy.java x: 5 lines of code y: 1 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/impl/CommonHttpSinkHandler.java x: 161 lines of code y: 4 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/HttpSourceConnector.java x: 159 lines of code y: 5 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/impl/CloudEventProtocol.java x: 57 lines of code y: 3 # changes eventmesh-admin-server/conf/application.yaml x: 37 lines of code y: 5 # changes eventmesh-admin-server/conf/eventmesh.sql x: 144 lines of code y: 9 # changes eventmesh-admin-server/conf/mapper/EventMeshMonitorMapper.xml x: 25 lines of code y: 1 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/HttpServer.java x: 143 lines of code y: 6 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/DruidDataSource.java x: 99 lines of code y: 1 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/EventMeshTaskInfoService.java x: 9 lines of code y: 2 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshTaskInfoServiceImpl.java x: 200 lines of code y: 2 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportJobRequestHandler.java x: 72 lines of code y: 2 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportMonitorHandler.java x: 69 lines of code y: 1 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportVerifyHandler.java x: 64 lines of code y: 3 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/job/JobInfoBizService.java x: 242 lines of code y: 6 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/monitor/MonitorBizService.java x: 82 lines of code y: 1 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/PositionHandler.java x: 5 lines of code y: 3 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/impl/HttpPositionHandler.java x: 38 lines of code y: 2 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/impl/MysqlPositionHandler.java x: 303 lines of code y: 5 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/task/TaskBizService.java x: 279 lines of code y: 5 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/utils/RSAUtils.java x: 209 lines of code y: 1 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/BaseRemoteResponse.java x: 35 lines of code y: 3 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/response/HttpResponseResult.java x: 35 lines of code y: 1 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/SqlUtils.java x: 790 lines of code y: 3 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/interceptor/SqlBuilderLoadInterceptor.java x: 76 lines of code y: 5 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalCheckConsumer.java x: 491 lines of code y: 1 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalFullConsumer.java x: 353 lines of code y: 1 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkCheckConnector.java x: 114 lines of code y: 2 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkFullConnector.java x: 115 lines of code y: 4 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkIncrementConnector.java x: 740 lines of code y: 2 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/EntryParser.java x: 283 lines of code y: 8 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/connector/CanalFullProducer.java x: 395 lines of code y: 3 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/connector/CanalSourceCheckConnector.java x: 178 lines of code y: 3 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/connector/CanalSourceIncrementConnector.java x: 369 lines of code y: 2 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/position/CanalFullPositionMgr.java x: 210 lines of code y: 3 # changes eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/connector/ConnectorRuntime.java x: 410 lines of code y: 9 # changes eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/Channel.java x: 75 lines of code y: 2 # changes eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/StandaloneBroker.java x: 78 lines of code y: 4 # changes eventmesh-connectors/eventmesh-connector-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/source/connector/ChatGPTSourceConnector.java x: 216 lines of code y: 4 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/impl/GitHubProtocol.java x: 120 lines of code y: 3 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/JdbcSourceConnector.java x: 119 lines of code y: 8 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/TaskManagerCoordinator.java x: 68 lines of code y: 4 # changes eventmesh-connectors/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/source/connector/KafkaSourceConnector.java x: 99 lines of code y: 11 # changes eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/source/connector/OpenFunctionSourceConnector.java x: 82 lines of code y: 19 # changes eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/source/connector/PravegaSourceConnector.java x: 173 lines of code y: 5 # changes eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/source/connector/RabbitMQSourceConnector.java x: 151 lines of code y: 9 # changes eventmesh-connectors/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/source/connector/RedisSourceConnector.java x: 92 lines of code y: 13 # changes eventmesh-function/eventmesh-function-filter/src/main/java/org/apache/eventmesh/function/filter/patternbuild/PatternBuilder.java x: 132 lines of code y: 1 # changes eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/function/FunctionRuntime.java x: 359 lines of code y: 2 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/FilterEngine.java x: 91 lines of code y: 3 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncEventProcessor.java x: 241 lines of code y: 73 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/impl/WebhookHttpSinkHandler.java x: 193 lines of code y: 3 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigService.java x: 152 lines of code y: 22 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/CanalSinkConfig.java x: 10 lines of code y: 5 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/JsonUtils.java x: 145 lines of code y: 20 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkConnector.java x: 66 lines of code y: 7 # changes eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java x: 11 lines of code y: 6 # changes eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnectorContext.java x: 16 lines of code y: 8 # changes eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/DefaultKeyValue.java x: 248 lines of code y: 5 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/FetchJobRequestHandler.java x: 43 lines of code y: 4 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportPositionHandler.java x: 75 lines of code y: 3 # changes eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-admin/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/admin/AdminOffsetService.java x: 221 lines of code y: 5 # changes eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/ConnectRecord.java x: 99 lines of code y: 9 # changes eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/boot/RuntimeInstance.java x: 114 lines of code y: 3 # changes eventmesh-runtime-v2/src/main/resources/connector.yaml x: 6 lines of code y: 4 # changes eventmesh-connectors/eventmesh-connector-dingtalk/src/main/java/org/apache/eventmesh/connector/dingtalk/sink/connector/DingDingSinkConnector.java x: 149 lines of code y: 6 # changes eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/sink/connector/FileSinkConnector.java x: 125 lines of code y: 4 # changes eventmesh-connectors/eventmesh-connector-file/src/main/java/org/apache/eventmesh/connector/file/source/connector/FileSourceConnector.java x: 99 lines of code y: 5 # changes eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/connector/MongodbSinkConnector.java x: 75 lines of code y: 10 # changes eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/sink/connector/OpenFunctionSinkConnector.java x: 68 lines of code y: 15 # changes eventmesh-connectors/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/source/connector/PulsarSourceConnector.java x: 90 lines of code y: 10 # changes eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/sink/connector/RabbitMQSinkConnector.java x: 95 lines of code y: 8 # changes eventmesh-connectors/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/sink/connector/RedisSinkConnector.java x: 71 lines of code y: 12 # changes eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/sink/connector/RocketMQSinkConnector.java x: 83 lines of code y: 15 # changes eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/source/connector/RocketMQSourceConnector.java x: 247 lines of code y: 12 # changes eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java x: 301 lines of code y: 33 # changes eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/Connector.java x: 13 lines of code y: 10 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/rdb/canal/CanalMySQLType.java x: 163 lines of code y: 1 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/remote/offset/RecordPosition.java x: 96 lines of code y: 2 # changes eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/admin/StandaloneAdmin.java x: 45 lines of code y: 9 # changes eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/model/MessageEntity.java x: 46 lines of code y: 4 # changes eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/task/Subscribe.java x: 68 lines of code y: 5 # changes eventmesh-trace-plugin/eventmesh-trace-pinpoint/src/main/java/org/apache/eventmesh/trace/pinpoint/exporter/PinpointSpanExporter.java x: 342 lines of code y: 29 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/Constants.java x: 95 lines of code y: 55 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ConfigurationContextUtil.java x: 26 lines of code y: 26 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/v2/ConfigurationHandler.java x: 149 lines of code y: 3 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshGrpcBootstrap.java x: 37 lines of code y: 16 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshHttpBootstrap.java x: 37 lines of code y: 28 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshServer.java x: 177 lines of code y: 83 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/SSLContextFactory.java x: 39 lines of code y: 32 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfiguration.java x: 64 lines of code y: 18 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/AdminMetricsProcessor.java x: 18 lines of code y: 14 # changes eventmesh-security-plugin/eventmesh-security-auth-token/src/main/java/org/apache/eventmesh/auth/token/impl/auth/AuthTokenUtils.java x: 94 lines of code y: 12 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver/AdminServiceGrpc.java x: 267 lines of code y: 1 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver/Metadata.java x: 732 lines of code y: 1 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver/Payload.java x: 667 lines of code y: 1 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/IPUtils.java x: 181 lines of code y: 39 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/model/EventColumn.java x: 122 lines of code y: 1 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/connection/JdbcConnection.java x: 274 lines of code y: 6 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/dialect/mysql/MysqlDatabaseDialect.java x: 334 lines of code y: 3 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/sink/handle/DefaultSinkRecordHandler.java x: 270 lines of code y: 2 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/listener/CreateTableParserListener.java x: 118 lines of code y: 6 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/mysql/MysqlCdcEngine.java x: 561 lines of code y: 8 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/AbstractSnapshotEngine.java x: 238 lines of code y: 4 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/mysql/MysqlSnapshotEngine.java x: 258 lines of code y: 6 # changes eventmesh-connectors/eventmesh-connector-lark/src/main/java/org/apache/eventmesh/connector/lark/sink/ImServiceHandler.java x: 271 lines of code y: 5 # changes eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/config/OpenFunctionServerConfig.java x: 13 lines of code y: 7 # changes eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SinkWorker.java x: 112 lines of code y: 15 # changes eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/RecordOffsetManagement.java x: 179 lines of code y: 5 # changes eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetManagementService.java x: 24 lines of code y: 7 # changes eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-nacos/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/nacos/NacosConfigService.java x: 166 lines of code y: 11 # changes eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshExtensionType.java x: 25 lines of code y: 18 # changes eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/RaftMetaService.java x: 334 lines of code y: 1 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigInfo.java x: 27 lines of code y: 9 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/constants/EventMeshVersion.java x: 106 lines of code y: 12 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/BannerUtil.java x: 46 lines of code y: 8 # changes style/checkStyle.xml x: 350 lines of code y: 18 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/ReplyMessageProcessor.java x: 199 lines of code y: 68 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/DeleteTopicProcessor.java x: 135 lines of code y: 14 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendSyncMessageProcessor.java x: 222 lines of code y: 68 # changes eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/TcpClient.java x: 169 lines of code y: 10 # changes eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/Metric.java x: 7 lines of code y: 9 # changes eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/PrometheusMetricsRegistry.java x: 50 lines of code y: 13 # changes eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/PrometheusMetricsRegistryManager.java x: 194 lines of code y: 1 # changes eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfiguration.java x: 12 lines of code y: 17 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/response/v1/GetMetricsResponse.java x: 136 lines of code y: 2 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshGrpcServer.java x: 228 lines of code y: 51 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/EventMeshConsumer.java x: 285 lines of code y: 48 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/PublishCloudEventsProcessor.java x: 58 lines of code y: 7 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/ReplyMessageProcessor.java x: 102 lines of code y: 22 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ConsumerService.java x: 122 lines of code y: 28 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java x: 219 lines of code y: 65 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageV2Processor.java x: 202 lines of code y: 61 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HeartBeatProcessor.java x: 161 lines of code y: 47 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncMessageProcessor.java x: 247 lines of code y: 76 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncRemoteEventProcessor.java x: 250 lines of code y: 67 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/UnSubscribeProcessor.java x: 201 lines of code y: 53 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java x: 619 lines of code y: 88 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java x: 226 lines of code y: 58 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send/SessionSender.java x: 170 lines of code y: 54 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/MonitorMetricConstants.java x: 17 lines of code y: 13 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/grpc/GrpcMetrics.java x: 184 lines of code y: 1 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/HttpMetrics.java x: 589 lines of code y: 1 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshThreadFactory.java x: 45 lines of code y: 10 # changes eventmesh-meta/eventmesh-meta-zookeeper/src/main/java/org/apache/eventmesh/meta/zookeeper/service/ZookeeperMetaService.java x: 276 lines of code y: 7 # changes eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolAdaptor.java x: 84 lines of code y: 31 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/constants/EventMeshConstants.java x: 104 lines of code y: 46 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/plugin/MQProducerWrapper.java x: 57 lines of code y: 27 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/plugin/MQWrapper.java x: 6 lines of code y: 18 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/HttpTinyClient.java x: 102 lines of code y: 24 # changes eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshCloudEventBuilder.java x: 226 lines of code y: 11 # changes eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/EventMeshGrpcConsumer.java x: 241 lines of code y: 9 # changes eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/SubStreamHandler.java x: 119 lines of code y: 14 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/convert/ConvertValue.java x: 35 lines of code y: 10 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/HttpResponseUtils.java x: 44 lines of code y: 26 # changes eventmesh-storage-plugin/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/config/ClientConfiguration.java x: 18 lines of code y: 4 # changes eventmesh-trace-plugin/eventmesh-trace-api/src/main/java/org/apache/eventmesh/trace/api/config/ExporterConfiguration.java x: 16 lines of code y: 19 # changes eventmesh-trace-plugin/eventmesh-trace-jaeger/src/main/java/org/apache/eventmesh/trace/jaeger/config/JaegerConfiguration.java x: 12 lines of code y: 12 # changes eventmesh-trace-plugin/eventmesh-trace-pinpoint/src/main/java/org/apache/eventmesh/trace/pinpoint/config/PinpointConfiguration.java x: 45 lines of code y: 30 # changes eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/java/org/apache/eventmesh/trace/zipkin/config/ZipkinConfiguration.java x: 12 lines of code y: 23 # changes eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/EventMeshMessageProducer.java x: 79 lines of code y: 9 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/Header.java x: 48 lines of code y: 11 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/codec/Codec.java x: 178 lines of code y: 44 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ThreadUtils.java x: 47 lines of code y: 15 # changes eventmesh-meta/eventmesh-meta-nacos/src/main/java/org/apache/eventmesh/meta/nacos/service/NacosMetaService.java x: 358 lines of code y: 8 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ServiceUtils.java x: 178 lines of code y: 27 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/RemotingHelper.java x: 55 lines of code y: 29 # changes eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/consumer/PushConsumerImpl.java x: 244 lines of code y: 7 # changes eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java x: 400 lines of code y: 5 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/HttpCommand.java x: 145 lines of code y: 27 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/NetUtils.java x: 44 lines of code y: 12 # changes eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/ProducerImpl.java x: 172 lines of code y: 6 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/ThreadPoolFactory.java x: 38 lines of code y: 18 # changes eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/MessageQueue.java x: 155 lines of code y: 8 # changes eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/util/CloudEventUtil.java x: 61 lines of code y: 8 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalUnSubscribeEventProcessor.java x: 203 lines of code y: 62 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteUnSubscribeEventProcessor.java x: 134 lines of code y: 60 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/antlr4/mysql/listener/ColumnDefinitionParserListener.java x: 203 lines of code y: 4 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/AbstractColumnEditorImpl.java x: 178 lines of code y: 4 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/Column.java x: 174 lines of code y: 3 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/table/catalog/TableSchema.java x: 137 lines of code y: 4 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/client/HeartbeatRequestBody.java x: 46 lines of code y: 19 # changes eventmesh-operator/config/crd/bases/eventmesh-operator.eventmesh_connectors.yaml x: 4036 lines of code y: 2 # changes eventmesh-operator/controllers/eventmesh_runtime/runtime_controller.go x: 261 lines of code y: 4 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/HeartbeatProcessor.java x: 95 lines of code y: 27 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/SubscribeStreamProcessor.java x: 111 lines of code y: 17 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/file/WatchFileTask.java x: 103 lines of code y: 27 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/CloudEventsAsyncSubscribe.java x: 42 lines of code y: 25 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/CloudEventsSubscribeReply.java x: 46 lines of code y: 28 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/EventMeshAsyncSubscribe.java x: 42 lines of code y: 12 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/WorkflowExpressAsyncSubscribe.java x: 73 lines of code y: 25 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/WorkflowOrderAsyncSubscribe.java x: 69 lines of code y: 26 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/WorkflowPaymentAsyncSubscribe.java x: 73 lines of code y: 29 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/app/controller/SubController.java x: 27 lines of code y: 21 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/app/service/SubService.java x: 86 lines of code y: 39 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshStartup.java x: 34 lines of code y: 44 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/SubscribeProcessor.java x: 108 lines of code y: 26 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java x: 270 lines of code y: 76 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/HttpClientGroupMapping.java x: 352 lines of code y: 26 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientSessionGroupMapping.java x: 430 lines of code y: 68 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/dispatch/FreePriorityDispatchStrategy.java x: 45 lines of code y: 22 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/processor/SubscribeProcessor.java x: 69 lines of code y: 6 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/recommend/EventMeshRecommendImpl.java x: 162 lines of code y: 27 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/EventMeshUtil.java x: 229 lines of code y: 64 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventMeshRebalanceService.java x: 42 lines of code y: 14 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/ConsumerGroupTopicConfig.java x: 38 lines of code y: 26 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/WebhookTopicConfig.java x: 84 lines of code y: 21 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/HandleMsgContext.java x: 68 lines of code y: 11 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/MessageHandler.java x: 59 lines of code y: 20 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/ProtocolKey.java x: 38 lines of code y: 6 # changes eventmesh-sdks/eventmesh-sdk-rust/src/model/subscription.rs x: 233 lines of code y: 2 # changes eventmesh-operator/config/crd/bases/eventmesh-operator.eventmesh_runtimes.yaml x: 8057 lines of code y: 1 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/common/EventMeshRetCode.java x: 40 lines of code y: 23 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/AbstractPushRequest.java x: 121 lines of code y: 17 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/retry/GrpcRetryer.java x: 12 lines of code y: 13 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/HandleMsgContext.java x: 186 lines of code y: 34 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/AbstractHTTPPushRequest.java x: 89 lines of code y: 23 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/retry/HttpRetryer.java x: 11 lines of code y: 28 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/DownStreamMsgContext.java x: 149 lines of code y: 40 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send/UpStreamMsgContext.java x: 119 lines of code y: 38 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/HTTPMessageHandler.java x: 68 lines of code y: 43 # changes eventmesh-sdks/eventmesh-sdk-rust/src/lib.rs x: 224 lines of code y: 2 # changes eventmesh-sdks/eventmesh-sdk-c/include/rmb_define.h x: 833 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/include/rmb_list.h x: 229 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/include/wemq_fifo.h x: 341 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/include/wemq_proto.h x: 365 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/src/rmb_context.c x: 751 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/src/rmb_log.c x: 990 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/src/rmb_mq.c x: 1092 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/src/rmb_msg.c x: 1386 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/src/rmb_pub.c x: 1946 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/src/rmb_sub.c x: 1040 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/src/rmb_udp.c x: 286 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/src/wemq_proto.c x: 618 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/src/wemq_tcp.c x: 630 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-c/src/wemq_thread.c x: 4790 lines of code y: 1 # changes eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/client/CloudEventsPublishInstance.java x: 56 lines of code y: 6 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/GrpcAbstractDemo.java x: 52 lines of code y: 14 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java x: 135 lines of code y: 44 # changes eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/MeshMessageProtocolAdaptor.java x: 113 lines of code y: 38 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionItem.java x: 60 lines of code y: 22 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionMode.java x: 13 lines of code y: 8 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/HttpEventWrapper.java x: 167 lines of code y: 25 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/WebhookProtocolTransportObject.java x: 15 lines of code y: 20 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/client/HeartbeatResponseBody.java x: 54 lines of code y: 18 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatResponseHeader.java x: 36 lines of code y: 15 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/message/ReplyMessageRequestHeader.java x: 37 lines of code y: 21 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/message/SendMessageBatchV2ResponseHeader.java x: 36 lines of code y: 20 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/Package.java x: 28 lines of code y: 23 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/UserAgent.java x: 117 lines of code y: 19 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/AssertUtils.java x: 16 lines of code y: 17 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/SystemUtils.java x: 42 lines of code y: 8 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/mysql/EventMeshGtidSet.java x: 336 lines of code y: 2 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/cloudevents/CloudEventsPublishInstance.java x: 26 lines of code y: 31 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/AsyncPublishInstance.java x: 26 lines of code y: 32 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/UtilsConstants.java x: 26 lines of code y: 12 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/util/Utils.java x: 53 lines of code y: 25 # changes eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/CloudEventsProtocolAdaptor.java x: 116 lines of code y: 37 # changes eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/resolver/HttpRequestProtocolResolver.java x: 66 lines of code y: 33 # changes eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/http/SendMessageBatchV2ProtocolResolver.java x: 55 lines of code y: 17 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/acl/Acl.java x: 182 lines of code y: 26 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/event/ConsumerGroupStateEvent.java x: 22 lines of code y: 15 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/plugin/MQAdminWrapper.java x: 62 lines of code y: 17 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/plugin/MQConsumerWrapper.java x: 45 lines of code y: 21 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/StreamPushRequest.java x: 86 lines of code y: 23 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/WebhookPushRequest.java x: 201 lines of code y: 37 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/ConsumerManager.java x: 149 lines of code y: 43 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/inf/Client.java x: 97 lines of code y: 21 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/HTTPClientPool.java x: 101 lines of code y: 31 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventMeshRebalanceImpl.java x: 217 lines of code y: 5 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/ClientAckContext.java x: 89 lines of code y: 26 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/trace/Trace.java x: 166 lines of code y: 23 # changes eventmesh-security-plugin/eventmesh-security-acl/src/main/java/org/apache/eventmesh/acl/impl/AclServiceImpl.java x: 27 lines of code y: 10 # changes eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/acl/AclService.java x: 14 lines of code y: 16 # changes eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshExtensionFactory.java x: 117 lines of code y: 24 # changes eventmesh-storage-plugin/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/consumer/PulsarConsumerImpl.java x: 158 lines of code y: 4 # changes eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/admin/RocketMQAdmin.java x: 104 lines of code y: 9 # changes eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/utils/CloudEventUtils.java x: 82 lines of code y: 7 # changes eventmesh-trace-plugin/eventmesh-trace-api/src/main/java/org/apache/eventmesh/trace/api/common/EventMeshTraceConstants.java x: 10 lines of code y: 20 # changes eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/java/org/apache/eventmesh/trace/zipkin/ZipkinTraceService.java x: 69 lines of code y: 39 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/antlr/MySqlLexer.g4 x: 1262 lines of code y: 1 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/antlr/MySqlParser.g4 x: 2411 lines of code y: 1 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/AsyncHttpProcessor.java x: 10 lines of code y: 19 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/EventMeshCloudEventUtils.java x: 254 lines of code y: 3 # changes eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/client/CallbackServiceGrpc.java x: 171 lines of code y: 9 # changes eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/http/SendMessageBatchV2ProtocolResolver.java x: 63 lines of code y: 19 # changes eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/http/SendMessageRequestProtocolResolver.java x: 63 lines of code y: 21 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/EventEmitter.java x: 34 lines of code y: 7 # changes eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/acl/AclProperties.java x: 75 lines of code y: 8 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/cloudevents/CloudEventsBatchPublishInstance.java x: 29 lines of code y: 25 # changes eventmesh-storage-plugin/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/producer/ProducerImpl.java x: 92 lines of code y: 7 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/ConsumerServiceGrpc.java x: 323 lines of code y: 4 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/PublisherServiceGrpc.java x: 453 lines of code y: 4 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/RandomStringUtils.java x: 13 lines of code y: 11 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/HTTPTrace.java x: 83 lines of code y: 24 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/message/SendMessageResponseBody.java x: 61 lines of code y: 16 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventMeshTrace.java x: 12 lines of code y: 15 # changes eventmesh-sdks/eventmesh-sdk-go/grpc/client.go x: 151 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-go/grpc/consumer.go x: 245 lines of code y: 1 # changes eventmesh-sdks/eventmesh-sdk-go/grpc/proto/eventmesh-client.pb.go x: 1271 lines of code y: 1 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventmeshRebalanceImpl.java x: 217 lines of code y: 30 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/ConsumerGroupManager.java x: 68 lines of code y: 14 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/client/UnRegRequestBody.java x: 64 lines of code y: 13 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/message/PushMessageRequestBody.java x: 96 lines of code y: 19 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/message/SendMessageRequestBody.java x: 118 lines of code y: 20 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/selector/NacosSelector.java x: 41 lines of code y: 19 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumer/ClientInfo.java x: 38 lines of code y: 9 # changes eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/exception/AclException.java x: 10 lines of code y: 14 # changes style/eventmesh-code-style.xml x: 282 lines of code y: 4 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/EventmeshSubscribeBroadcast.java x: 42 lines of code y: 13 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/catalog/protos/CatalogGrpc.java x: 278 lines of code y: 6 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/workflow/protos/WorkflowGrpc.java x: 214 lines of code y: 6 # changes
92.0
# changes
  min: 1.0
  average: 6.28
  25th percentile: 1.0
  median: 2.0
  75th percentile: 5.0
  max: 92.0
0 8057.0
lines of code
min: 2.0 | average: 75.15 | 25th percentile: 12.0 | median: 29.0 | 75th percentile: 69.0 | max: 8057.0

Number of Contributors vs. Number of Changes: 1667 points

eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/AbstractHttpHandler.java x: 8 # contributors y: 11 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java x: 40 # contributors y: 84 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractRemotingServer.java x: 27 # contributors y: 38 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshAdminServer.java x: 3 # contributors y: 5 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HandlerService.java x: 30 # contributors y: 52 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/EventMeshTcp2Client.java x: 18 # contributors y: 28 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/processor/HelloProcessor.java x: 4 # contributors y: 6 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/processor/MessageTransferProcessor.java x: 3 # contributors y: 4 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/SessionPusher.java x: 36 # contributors y: 58 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/Utils.java x: 29 # contributors y: 43 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatRequestHeader.java x: 16 # contributors y: 22 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeader.java x: 14 # contributors y: 17 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/CommonConfiguration.java x: 37 # contributors y: 80 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/AdminHandlerManager.java x: 3 # contributors y: 6 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/v1/ConfigurationHandlerV1.java x: 1 # contributors y: 2 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshHTTPServer.java x: 41 # contributors y: 92 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshTCPServer.java x: 40 # contributors y: 82 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshHTTPConfiguration.java x: 26 # contributors y: 44 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalSubscribeEventProcessor.java x: 35 # contributors y: 62 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteSubscribeEventProcessor.java x: 35 # contributors y: 63 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SubscribeProcessor.java x: 36 # contributors y: 63 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/AsyncHTTPPushRequest.java x: 36 # contributors y: 78 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/ExampleAdminServer.java x: 2 # contributors y: 5 # changes tools/dist-license/licenses/java/AL 2.0-downloaded-LICENSE-2.0.html x: 2 # contributors y: 2 # changes eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/serialize/EventMeshHessianSerializer.java x: 1 # contributors y: 1 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/HttpSinkConnector.java x: 2 # contributors y: 7 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/data/HttpExportMetadata.java x: 2 # contributors y: 3 # changes eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/impl/CloudEventProtocol.java x: 3 # contributors y: 3 # changes eventmesh-admin-server/conf/eventmesh.sql x: 2 # contributors y: 9 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/AdminServerProperties.java x: 1 # contributors y: 3 # changes eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/HttpServer.java x: 2 # contributors y: 6 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/interceptor/SqlBuilderLoadInterceptor.java x: 1 # contributors y: 5 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkFullConnector.java x: 2 # contributors y: 4 # changes eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/EntryParser.java x: 2 # contributors y: 8 # changes eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/StandaloneBroker.java x: 4 # contributors y: 4 # changes eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/JdbcSourceConnector.java x: 4 # contributors y: 8 # changes eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/source/connector/OpenFunctionSourceConnector.java x: 10 # contributors y: 19 # changes eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/source/connector/PravegaSourceConnector.java x: 4 # contributors y: 5 # changes eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/source/connector/RabbitMQSourceConnector.java x: 5 # contributors y: 9 # changes eventmesh-connectors/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/source/connector/RedisSourceConnector.java x: 8 # contributors y: 13 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncEventProcessor.java x: 40 # contributors y: 73 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigService.java x: 15 # contributors y: 22 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/JsonUtils.java x: 13 # contributors y: 20 # changes eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java x: 5 # contributors y: 6 # changes eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SourceConnectorContext.java x: 5 # contributors y: 8 # changes eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/ConnectRecord.java x: 4 # contributors y: 9 # changes eventmesh-runtime-v2/src/main/resources/connector.yaml x: 1 # contributors y: 4 # changes eventmesh-connectors/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/sink/connector/KafkaSinkConnector.java x: 6 # contributors y: 9 # changes eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/connector/MongodbSinkConnector.java x: 6 # contributors y: 10 # changes eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/sink/connector/OpenFunctionSinkConnector.java x: 8 # contributors y: 15 # changes eventmesh-connectors/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/sink/connector/PulsarSinkConnector.java x: 7 # contributors y: 10 # changes eventmesh-connectors/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/sink/connector/RedisSinkConnector.java x: 7 # contributors y: 12 # changes eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/source/connector/RocketMQSourceConnector.java x: 6 # contributors y: 12 # changes eventmesh-connectors/eventmesh-connector-s3/src/main/java/org/apache/eventmesh/connector/s3/source/connector/S3SourceConnector.java x: 6 # contributors y: 8 # changes eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java x: 16 # contributors y: 33 # changes eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/admin/StandaloneAdmin.java x: 8 # contributors y: 9 # changes eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/task/Subscribe.java x: 6 # contributors y: 5 # changes eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/consumer/StandaloneConsumer.java x: 5 # contributors y: 4 # changes eventmesh-trace-plugin/eventmesh-trace-pinpoint/src/main/java/org/apache/eventmesh/trace/pinpoint/exporter/PinpointSpanExporter.java x: 21 # contributors y: 29 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/Constants.java x: 33 # contributors y: 55 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ConfigurationContextUtil.java x: 17 # contributors y: 26 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshGrpcBootstrap.java x: 12 # contributors y: 16 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshHttpBootstrap.java x: 19 # contributors y: 28 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshServer.java x: 41 # contributors y: 83 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/SSLContextFactory.java x: 24 # contributors y: 32 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfiguration.java x: 13 # contributors y: 18 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshTCPConfiguration.java x: 25 # contributors y: 38 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/AdminMetricsProcessor.java x: 13 # contributors y: 14 # changes eventmesh-security-plugin/eventmesh-security-auth-token/src/main/java/org/apache/eventmesh/auth/token/impl/auth/AuthTokenUtils.java x: 8 # contributors y: 12 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/FileLoad.java x: 13 # contributors y: 15 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/IPUtils.java x: 25 # contributors y: 39 # changes eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/config/OpenFunctionServerConfig.java x: 5 # contributors y: 7 # changes eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/Application.java x: 7 # contributors y: 13 # changes eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetManagementService.java x: 3 # contributors y: 7 # changes eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-nacos/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/nacos/NacosConfigService.java x: 7 # contributors y: 11 # changes eventmesh-runtime/conf/log4j2.xml x: 4 # contributors y: 7 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigInfo.java x: 11 # contributors y: 9 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/constants/EventMeshVersion.java x: 11 # contributors y: 12 # changes style/checkStyle.xml x: 14 # contributors y: 18 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/ReplyMessageProcessor.java x: 39 # contributors y: 68 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/DeleteTopicProcessor.java x: 11 # contributors y: 14 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendSyncMessageProcessor.java x: 35 # contributors y: 68 # changes eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/TcpClient.java x: 8 # contributors y: 10 # changes eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPSubClient.java x: 6 # contributors y: 6 # changes eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/MetricsRegistry.java x: 12 # contributors y: 14 # changes eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/PrometheusMetricsRegistry.java x: 11 # contributors y: 13 # changes eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfiguration.java x: 15 # contributors y: 17 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshGrpcServer.java x: 27 # contributors y: 51 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/EventMeshConsumer.java x: 27 # contributors y: 48 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/ReplyMessageProcessor.java x: 12 # contributors y: 22 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ConsumerService.java x: 16 # contributors y: 28 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java x: 40 # contributors y: 65 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageV2Processor.java x: 36 # contributors y: 61 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/CreateTopicProcessor.java x: 12 # contributors y: 15 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HeartBeatProcessor.java x: 33 # contributors y: 47 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/QuerySubscriptionProcessor.java x: 9 # contributors y: 10 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncMessageProcessor.java x: 40 # contributors y: 76 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncRemoteEventProcessor.java x: 33 # contributors y: 67 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/UnSubscribeProcessor.java x: 31 # contributors y: 53 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java x: 47 # contributors y: 88 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java x: 35 # contributors y: 58 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send/SessionSender.java x: 32 # contributors y: 54 # changes eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolAdaptor.java x: 20 # contributors y: 31 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/constants/EventMeshConstants.java x: 32 # contributors y: 46 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/plugin/MQProducerWrapper.java x: 19 # contributors y: 27 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/plugin/MQWrapper.java x: 16 # contributors y: 18 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/HttpTinyClient.java x: 17 # contributors y: 24 # changes eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/SubStreamHandler.java x: 8 # contributors y: 14 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/convert/ConvertValue.java x: 12 # contributors y: 10 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/convert/ConverterMap.java x: 9 # contributors y: 8 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/convert/converter/ObjectConverter.java x: 9 # contributors y: 9 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/HttpResponseUtils.java x: 15 # contributors y: 26 # changes eventmesh-security-plugin/eventmesh-security-auth-http-basic/src/main/java/org/apache/eventmesh/auth/http/basic/config/AuthConfigs.java x: 13 # contributors y: 17 # changes eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/config/ClientConfiguration.java x: 4 # contributors y: 3 # changes eventmesh-trace-plugin/eventmesh-trace-api/src/main/java/org/apache/eventmesh/trace/api/config/ExporterConfiguration.java x: 15 # contributors y: 19 # changes eventmesh-trace-plugin/eventmesh-trace-jaeger/src/main/java/org/apache/eventmesh/trace/jaeger/config/JaegerConfiguration.java x: 9 # contributors y: 12 # changes eventmesh-trace-plugin/eventmesh-trace-pinpoint/src/main/java/org/apache/eventmesh/trace/pinpoint/config/PinpointConfiguration.java x: 19 # contributors y: 30 # changes eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/java/org/apache/eventmesh/trace/zipkin/config/ZipkinConfiguration.java x: 15 # contributors y: 23 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/codec/Codec.java x: 28 # contributors y: 44 # changes eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcEventMeshCloudEventProtocolResolver.java x: 5 # contributors y: 5 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ServiceUtils.java x: 17 # contributors y: 27 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/RemotingHelper.java x: 20 # contributors y: 29 # changes eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/consumer/PushConsumerImpl.java x: 8 # contributors y: 7 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/HttpCommand.java x: 21 # contributors y: 27 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/NetUtils.java x: 10 # contributors y: 12 # changes eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/ProducerImpl.java x: 8 # contributors y: 6 # changes eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/MessageQueue.java x: 8 # contributors y: 8 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HttpProcessor.java x: 10 # contributors y: 17 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalUnSubscribeEventProcessor.java x: 36 # contributors y: 62 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/RemoteUnSubscribeEventProcessor.java x: 36 # contributors y: 60 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/inf/HttpRequestProcessor.java x: 16 # contributors y: 17 # changes eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/EventMeshHttpConsumer.java x: 7 # contributors y: 9 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/SubscribeStreamProcessor.java x: 11 # contributors y: 17 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/file/WatchFileTask.java x: 16 # contributors y: 27 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/WorkflowAsyncPublishInstance.java x: 22 # contributors y: 30 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/CloudEventsAsyncSubscribe.java x: 19 # contributors y: 25 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/CloudEventsSubscribeReply.java x: 22 # contributors y: 28 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/EventMeshAsyncSubscribe.java x: 12 # contributors y: 12 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/WorkflowExpressAsyncSubscribe.java x: 20 # contributors y: 25 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/WorkflowOrderAsyncSubscribe.java x: 22 # contributors y: 26 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/WorkflowPaymentAsyncSubscribe.java x: 24 # contributors y: 29 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/app/controller/SubController.java x: 19 # contributors y: 21 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/app/service/SubService.java x: 28 # contributors y: 39 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshStartup.java x: 24 # contributors y: 44 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/StreamTopicConfig.java x: 16 # contributors y: 25 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java x: 41 # contributors y: 76 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientSessionGroupMapping.java x: 33 # contributors y: 68 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/recommend/EventMeshRecommendImpl.java x: 18 # contributors y: 27 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/EventMeshUtil.java x: 35 # contributors y: 64 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/WebhookTopicConfig.java x: 14 # contributors y: 21 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/HandleMsgContext.java x: 9 # contributors y: 11 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/MessageHandler.java x: 12 # contributors y: 20 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/common/EventMeshRetCode.java x: 13 # contributors y: 23 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/common/ProtocolKey.java x: 16 # contributors y: 30 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/AbstractPushRequest.java x: 12 # contributors y: 17 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/retry/GrpcRetryer.java x: 12 # contributors y: 13 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/HandleMsgContext.java x: 22 # contributors y: 34 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/AbstractHTTPPushRequest.java x: 19 # contributors y: 23 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/retry/HttpRetryer.java x: 23 # contributors y: 28 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/DownStreamMsgContext.java x: 27 # contributors y: 40 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send/UpStreamMsgContext.java x: 26 # contributors y: 38 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/HTTPMessageHandler.java x: 25 # contributors y: 43 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java x: 31 # contributors y: 44 # changes eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/MeshMessageProtocolAdaptor.java x: 24 # contributors y: 38 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/convert/converter/ListConverter.java x: 10 # contributors y: 10 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/loadbalance/LoadBalanceType.java x: 10 # contributors y: 9 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/HttpEventWrapper.java x: 18 # contributors y: 25 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/WebhookProtocolTransportObject.java x: 15 # contributors y: 20 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/client/HeartbeatResponseBody.java x: 15 # contributors y: 18 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/message/SendMessageBatchRequestBody.java x: 14 # contributors y: 15 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/common/RequestURI.java x: 10 # contributors y: 13 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/RegResponseHeader.java x: 14 # contributors y: 16 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/message/ReplyMessageRequestHeader.java x: 15 # contributors y: 21 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/message/SendMessageBatchV2ResponseHeader.java x: 16 # contributors y: 20 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/Package.java x: 16 # contributors y: 23 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/PropertiesUtils.java x: 14 # contributors y: 22 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/cloudevents/CloudEventsPublishInstance.java x: 19 # contributors y: 31 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/AsyncPublishInstance.java x: 19 # contributors y: 32 # changes eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/CloudEventsProtocolAdaptor.java x: 23 # contributors y: 37 # changes eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/tcp/TcpMessageProtocolResolver.java x: 17 # contributors y: 22 # changes eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolConstant.java x: 7 # contributors y: 14 # changes eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/resolver/HttpRequestProtocolResolver.java x: 22 # contributors y: 33 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/acl/Acl.java x: 16 # contributors y: 26 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ConsumerGroupConf.java x: 17 # contributors y: 18 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/plugin/MQConsumerWrapper.java x: 16 # contributors y: 21 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/WebhookPushRequest.java x: 24 # contributors y: 37 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/HeartbeatService.java x: 14 # contributors y: 23 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/ConsumerManager.java x: 31 # contributors y: 43 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/HTTPClientPool.java x: 22 # contributors y: 31 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/SessionContext.java x: 14 # contributors y: 14 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/ClientAckContext.java x: 21 # contributors y: 26 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/PushContext.java x: 17 # contributors y: 19 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/trace/LogExporter.java x: 10 # contributors y: 11 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/TraceUtils.java x: 3 # contributors y: 2 # changes eventmesh-security-plugin/eventmesh-security-acl/src/main/java/org/apache/eventmesh/acl/impl/AclServiceImpl.java x: 11 # contributors y: 10 # changes eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/acl/AclService.java x: 15 # contributors y: 16 # changes eventmesh-spi/src/main/java/org/apache/eventmesh/spi/loader/JarExtensionClassLoader.java x: 15 # contributors y: 24 # changes eventmesh-spi/src/main/java/org/apache/eventmesh/spi/loader/MetaInfExtensionClassLoader.java x: 9 # contributors y: 15 # changes eventmesh-storage-plugin/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/consumer/ConsumerImpl.java x: 6 # contributors y: 3 # changes eventmesh-storage-plugin/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/client/PulsarClientWrapper.java x: 7 # contributors y: 5 # changes eventmesh-storage-plugin/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/consumer/PulsarConsumerImpl.java x: 7 # contributors y: 4 # changes eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/cloudevent/impl/RocketMQMessageWriter.java x: 7 # contributors y: 6 # changes eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/java/org/apache/eventmesh/trace/zipkin/ZipkinTraceService.java x: 24 # contributors y: 39 # changes eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/http/SendMessageBatchV2ProtocolResolver.java x: 12 # contributors y: 19 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/EventEmitter.java x: 6 # contributors y: 7 # changes eventmesh-storage-plugin/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/producer/ProducerImpl.java x: 12 # contributors y: 7 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/HTTPTrace.java x: 13 # contributors y: 24 # changes eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/EventMeshTrace.java x: 10 # contributors y: 15 # changes eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/tcp/TcpMessageProtocolResolver.java x: 22 # contributors y: 29 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/enums/EventMeshProtocolType.java x: 4 # contributors y: 2 # changes eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java x: 5 # contributors y: 2 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigMonitorService.java x: 7 # contributors y: 7 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/loadbalance/WeightRandomLoadBalanceSelector.java x: 13 # contributors y: 16 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/BaseRequestBody.java x: 11 # contributors y: 18 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/client/SubscribeResponseBody.java x: 16 # contributors y: 19 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/client/UnSubscribeResponseBody.java x: 12 # contributors y: 18 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/message/PushMessageRequestBody.java x: 13 # contributors y: 19 # changes eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/message/SendMessageRequestBody.java x: 14 # contributors y: 20 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/common/ExampleConstants.java x: 15 # contributors y: 15 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/selector/NacosSelector.java x: 18 # contributors y: 19 # changes eventmesh-protocol-plugin/eventmesh-protocol-openmessage/src/main/java/org/apache/eventmesh/protocol/openmessage/OpenMessageProtocolAdaptor.java x: 9 # contributors y: 13 # changes eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/EventmeshAsyncSubscribe.java x: 11 # contributors y: 16 # changes
92.0
# changes
  min: 1.0
  average: 6.28
  25th percentile: 1.0
  median: 2.0
  75th percentile: 5.0
  max: 92.0
0 47.0
# contributors
min: 1.0 | average: 4.63 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 5.0 | max: 47.0

Number of Contributors vs. File Size: 1667 points

eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/AbstractHttpHandler.java x: 8 # contributors y: 107 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java x: 40 # contributors y: 406 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractRemotingServer.java x: 27 # contributors y: 80 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractTCPServer.java x: 8 # contributors y: 391 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshAdminServer.java x: 3 # contributors y: 144 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HandlerService.java x: 30 # contributors y: 298 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/EventMeshTcp2Client.java x: 18 # contributors y: 112 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/processor/HelloProcessor.java x: 4 # contributors y: 91 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/processor/MessageTransferProcessor.java x: 3 # contributors y: 225 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/SessionPusher.java x: 36 # contributors y: 132 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/Utils.java x: 29 # contributors y: 99 lines of code eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java x: 3 # contributors y: 56 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatRequestHeader.java x: 16 # contributors y: 35 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeader.java x: 14 # contributors y: 35 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/config/CommonConfiguration.java x: 37 # contributors y: 78 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/AdminHandlerManager.java x: 3 # contributors y: 77 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/v1/ConfigurationHandlerV1.java x: 1 # contributors y: 47 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshHTTPServer.java x: 41 # contributors y: 196 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshTCPServer.java x: 40 # contributors y: 188 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshHTTPConfiguration.java x: 26 # contributors y: 76 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/LocalSubscribeEventProcessor.java x: 35 # contributors y: 139 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/AsyncHTTPPushRequest.java x: 36 # contributors y: 309 lines of code eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/ExampleAdminServer.java x: 2 # contributors y: 16 lines of code tools/dist-license/licenses/java/AL 2.0-downloaded-LICENSE-2.0.html x: 2 # contributors y: 485 lines of code eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/MetaStateMachine.java x: 1 # contributors y: 149 lines of code eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/serialize/EventMeshSerializerFactory.java x: 1 # contributors y: 112 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/http/SinkConnectorConfig.java x: 1 # contributors y: 26 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/http/SourceConnectorConfig.java x: 3 # contributors y: 17 lines of code eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/HttpSinkConnector.java x: 2 # contributors y: 131 lines of code eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/impl/CommonHttpSinkHandler.java x: 3 # contributors y: 161 lines of code eventmesh-admin-server/conf/application.yaml x: 2 # contributors y: 37 lines of code eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/db/service/impl/EventMeshTaskInfoServiceImpl.java x: 2 # contributors y: 200 lines of code eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportJobRequestHandler.java x: 1 # contributors y: 72 lines of code eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/handler/impl/ReportVerifyHandler.java x: 2 # contributors y: 64 lines of code eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/job/JobInfoBizService.java x: 2 # contributors y: 242 lines of code eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/position/impl/MysqlPositionHandler.java x: 2 # contributors y: 303 lines of code eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/service/task/TaskBizService.java x: 2 # contributors y: 279 lines of code eventmesh-admin-server/src/main/java/org/apache/eventmesh/admin/server/web/utils/RSAUtils.java x: 1 # contributors y: 209 lines of code eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/SqlUtils.java x: 2 # contributors y: 790 lines of code eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalCheckConsumer.java x: 1 # contributors y: 491 lines of code eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalFullConsumer.java x: 1 # contributors y: 353 lines of code eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkFullConnector.java x: 2 # contributors y: 115 lines of code eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/sink/connector/CanalSinkIncrementConnector.java x: 1 # contributors y: 740 lines of code eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/connector/CanalFullProducer.java x: 2 # contributors y: 395 lines of code eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/source/connector/CanalSourceCheckConnector.java x: 2 # contributors y: 178 lines of code eventmesh-connectors/eventmesh-connector-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/source/connector/ChatGPTSourceConnector.java x: 3 # contributors y: 216 lines of code eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/impl/GitHubProtocol.java x: 3 # contributors y: 120 lines of code eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/JdbcSourceConnector.java x: 4 # contributors y: 119 lines of code eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/source/connector/MongodbSourceConnector.java x: 8 # contributors y: 91 lines of code eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/source/connector/OpenFunctionSourceConnector.java x: 10 # contributors y: 82 lines of code eventmesh-connectors/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/source/connector/PravegaSourceConnector.java x: 4 # contributors y: 173 lines of code eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/source/connector/RabbitMQSourceConnector.java x: 5 # contributors y: 151 lines of code eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/function/FunctionRuntime.java x: 2 # contributors y: 359 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncEventProcessor.java x: 40 # contributors y: 241 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigService.java x: 15 # contributors y: 152 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/JsonUtils.java x: 13 # contributors y: 145 lines of code eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/SinkConnectorContext.java x: 5 # contributors y: 11 lines of code eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-api/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/api/data/DefaultKeyValue.java x: 4 # contributors y: 248 lines of code eventmesh-connectors/eventmesh-connector-canal/src/main/java/org/apache/eventmesh/connector/canal/CanalConnectRecord.java x: 1 # contributors y: 177 lines of code eventmesh-connectors/eventmesh-connector-dingtalk/src/main/java/org/apache/eventmesh/connector/dingtalk/sink/connector/DingDingSinkConnector.java x: 4 # contributors y: 149 lines of code eventmesh-connectors/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/sink/connector/KafkaSinkConnector.java x: 6 # contributors y: 97 lines of code eventmesh-connectors/eventmesh-connector-mongodb/src/main/java/org/apache/eventmesh/connector/mongodb/sink/connector/MongodbSinkConnector.java x: 6 # contributors y: 75 lines of code eventmesh-connectors/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/sink/connector/PulsarSinkConnector.java x: 7 # contributors y: 81 lines of code eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/source/connector/RocketMQSourceConnector.java x: 6 # contributors y: 247 lines of code eventmesh-connectors/eventmesh-connector-s3/src/main/java/org/apache/eventmesh/connector/s3/source/connector/S3SourceConnector.java x: 6 # contributors y: 128 lines of code eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java x: 16 # contributors y: 301 lines of code eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/api/connector/Connector.java x: 6 # contributors y: 13 lines of code eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/admin/StandaloneAdmin.java x: 8 # contributors y: 45 lines of code eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/model/MessageEntity.java x: 4 # contributors y: 46 lines of code eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/consumer/StandaloneConsumer.java x: 5 # contributors y: 73 lines of code eventmesh-trace-plugin/eventmesh-trace-pinpoint/src/main/java/org/apache/eventmesh/trace/pinpoint/exporter/PinpointSpanExporter.java x: 21 # contributors y: 342 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/Constants.java x: 33 # contributors y: 95 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ConfigurationContextUtil.java x: 17 # contributors y: 26 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshGrpcBootstrap.java x: 12 # contributors y: 37 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshHttpBootstrap.java x: 19 # contributors y: 37 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshServer.java x: 41 # contributors y: 177 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshTcpBootstrap.java x: 15 # contributors y: 37 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/SSLContextFactory.java x: 24 # contributors y: 39 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshGrpcConfiguration.java x: 13 # contributors y: 64 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/EventMeshTCPConfiguration.java x: 25 # contributors y: 87 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/AdminMetricsProcessor.java x: 13 # contributors y: 18 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver/AdminServiceGrpc.java x: 1 # contributors y: 267 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/adminserver/Payload.java x: 1 # contributors y: 667 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/IPUtils.java x: 25 # contributors y: 181 lines of code eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/connection/JdbcConnection.java x: 5 # contributors y: 274 lines of code eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/dialect/mysql/MysqlDatabaseDialect.java x: 3 # contributors y: 334 lines of code eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/mysql/MysqlCdcEngine.java x: 5 # contributors y: 561 lines of code eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/snapshot/mysql/MysqlSnapshotEngine.java x: 4 # contributors y: 258 lines of code eventmesh-connectors/eventmesh-connector-lark/src/main/java/org/apache/eventmesh/connector/lark/sink/ImServiceHandler.java x: 3 # contributors y: 271 lines of code eventmesh-connectors/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/RocketMQServerConfig.java x: 4 # contributors y: 10 lines of code eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/Application.java x: 7 # contributors y: 96 lines of code eventmesh-openconnect/eventmesh-openconnect-offsetmgmt-plugin/eventmesh-openconnect-offsetmgmt-nacos/src/main/java/org/apache/eventmesh/openconnect/offsetmgmt/nacos/NacosConfigService.java x: 7 # contributors y: 166 lines of code eventmesh-meta/eventmesh-meta-raft/src/main/java/org/apache/eventmesh/meta/raft/RaftMetaService.java x: 1 # contributors y: 334 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/config/ConfigInfo.java x: 11 # contributors y: 27 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/constants/EventMeshVersion.java x: 11 # contributors y: 106 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/BannerUtil.java x: 5 # contributors y: 46 lines of code style/checkStyle.xml x: 14 # contributors y: 350 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/ReplyMessageProcessor.java x: 39 # contributors y: 199 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/DeleteTopicProcessor.java x: 11 # contributors y: 135 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendSyncMessageProcessor.java x: 35 # contributors y: 222 lines of code eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/TcpClient.java x: 8 # contributors y: 169 lines of code eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/MetricsRegistry.java x: 12 # contributors y: 18 lines of code eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/Metric.java x: 8 # contributors y: 7 lines of code eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/PrometheusMetricsRegistry.java x: 11 # contributors y: 50 lines of code eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfiguration.java x: 15 # contributors y: 12 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshGrpcServer.java x: 27 # contributors y: 228 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/EventMeshConsumer.java x: 27 # contributors y: 285 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/ReplyMessageProcessor.java x: 12 # contributors y: 102 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ConsumerService.java x: 16 # contributors y: 122 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageProcessor.java x: 40 # contributors y: 219 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/BatchSendMessageV2Processor.java x: 36 # contributors y: 202 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HeartBeatProcessor.java x: 33 # contributors y: 161 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/QuerySubscriptionProcessor.java x: 9 # contributors y: 86 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncRemoteEventProcessor.java x: 33 # contributors y: 250 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/UnSubscribeProcessor.java x: 31 # contributors y: 201 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java x: 47 # contributors y: 619 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java x: 35 # contributors y: 226 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send/SessionSender.java x: 32 # contributors y: 170 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/HttpMetrics.java x: 1 # contributors y: 589 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshThreadFactory.java x: 9 # contributors y: 45 lines of code eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolAdaptor.java x: 20 # contributors y: 84 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/constants/EventMeshConstants.java x: 32 # contributors y: 104 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/plugin/MQWrapper.java x: 16 # contributors y: 6 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/HttpTinyClient.java x: 17 # contributors y: 102 lines of code eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshCloudEventBuilder.java x: 8 # contributors y: 226 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/config/convert/converter/ObjectConverter.java x: 9 # contributors y: 155 lines of code eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/config/ConfigurationHolder.java x: 6 # contributors y: 33 lines of code eventmesh-trace-plugin/eventmesh-trace-jaeger/src/main/java/org/apache/eventmesh/trace/jaeger/config/JaegerConfiguration.java x: 9 # contributors y: 12 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/codec/Codec.java x: 28 # contributors y: 178 lines of code eventmesh-meta/eventmesh-meta-nacos/src/main/java/org/apache/eventmesh/meta/nacos/service/NacosMetaService.java x: 4 # contributors y: 358 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ServiceUtils.java x: 17 # contributors y: 178 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/RemotingHelper.java x: 20 # contributors y: 55 lines of code eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java x: 6 # contributors y: 400 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/HttpCommand.java x: 21 # contributors y: 145 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/NetUtils.java x: 10 # contributors y: 44 lines of code eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/MessageQueue.java x: 8 # contributors y: 155 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HttpProcessor.java x: 10 # contributors y: 11 lines of code eventmesh-connectors/eventmesh-connector-jdbc/src/main/java/org/apache/eventmesh/connector/jdbc/source/dialect/cdc/mysql/RowDeserializers.java x: 2 # contributors y: 329 lines of code eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/EventMeshHttpConsumer.java x: 7 # contributors y: 139 lines of code eventmesh-operator/config/crd/bases/eventmesh-operator.eventmesh_connectors.yaml x: 1 # contributors y: 4036 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/HeartbeatProcessor.java x: 17 # contributors y: 95 lines of code eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/WorkflowAsyncPublishInstance.java x: 22 # contributors y: 44 lines of code eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/WorkflowOrderAsyncSubscribe.java x: 22 # contributors y: 69 lines of code eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/WorkflowPaymentAsyncSubscribe.java x: 24 # contributors y: 73 lines of code eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/app/controller/SubController.java x: 19 # contributors y: 27 lines of code eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/app/service/SubService.java x: 28 # contributors y: 86 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java x: 26 # contributors y: 185 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/StreamTopicConfig.java x: 16 # contributors y: 85 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/EventMeshConsumer.java x: 41 # contributors y: 270 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/HttpClientGroupMapping.java x: 15 # contributors y: 352 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientSessionGroupMapping.java x: 33 # contributors y: 430 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/recommend/EventMeshRecommendImpl.java x: 18 # contributors y: 162 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/WebhookTopicConfig.java x: 14 # contributors y: 84 lines of code eventmesh-sdks/eventmesh-sdk-rust/src/model/subscription.rs x: 1 # contributors y: 233 lines of code eventmesh-operator/config/crd/bases/eventmesh-operator.eventmesh_runtimes.yaml x: 1 # contributors y: 8057 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/common/EventMeshRetCode.java x: 13 # contributors y: 40 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/consumer/HandleMsgContext.java x: 22 # contributors y: 186 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/AbstractHTTPPushRequest.java x: 19 # contributors y: 89 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/retry/HttpRetryer.java x: 23 # contributors y: 11 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/DownStreamMsgContext.java x: 27 # contributors y: 149 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send/UpStreamMsgContext.java x: 26 # contributors y: 119 lines of code eventmesh-sdks/eventmesh-sdk-c/include/rmb_define.h x: 1 # contributors y: 833 lines of code eventmesh-sdks/eventmesh-sdk-c/src/rmb_log.c x: 1 # contributors y: 990 lines of code eventmesh-sdks/eventmesh-sdk-c/src/rmb_mq.c x: 1 # contributors y: 1092 lines of code eventmesh-sdks/eventmesh-sdk-c/src/rmb_msg.c x: 1 # contributors y: 1386 lines of code eventmesh-sdks/eventmesh-sdk-c/src/rmb_pub.c x: 1 # contributors y: 1946 lines of code eventmesh-sdks/eventmesh-sdk-c/src/rmb_sub.c x: 1 # contributors y: 1040 lines of code eventmesh-sdks/eventmesh-sdk-c/src/rmb_udp.c x: 1 # contributors y: 286 lines of code eventmesh-sdks/eventmesh-sdk-c/src/wemq_proto.c x: 1 # contributors y: 618 lines of code eventmesh-sdks/eventmesh-sdk-c/src/wemq_thread.c x: 1 # contributors y: 4790 lines of code eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java x: 31 # contributors y: 135 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/inf/AbstractEventProcessor.java x: 24 # contributors y: 144 lines of code eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/MeshMessageProtocolAdaptor.java x: 24 # contributors y: 113 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/loadbalance/RandomLoadBalanceSelector.java x: 14 # contributors y: 24 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/message/SendMessageBatchRequestBody.java x: 14 # contributors y: 102 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/UserAgent.java x: 15 # contributors y: 117 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/HttpConvertsUtils.java x: 6 # contributors y: 169 lines of code eventmesh-connectors/eventmesh-connector-openfunction/src/main/java/org/apache/eventmesh/connector/openfunction/service/ConsumerService.java x: 7 # contributors y: 56 lines of code eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/CloudEventsProtocolAdaptor.java x: 23 # contributors y: 116 lines of code eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/tcp/TcpMessageProtocolResolver.java x: 17 # contributors y: 48 lines of code eventmesh-protocol-plugin/eventmesh-protocol-http/src/main/java/org/apache/eventmesh/protocol/http/HttpProtocolConstant.java x: 7 # contributors y: 19 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/acl/Acl.java x: 16 # contributors y: 182 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumer/SubscriptionManager.java x: 12 # contributors y: 136 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/StreamPushRequest.java x: 15 # contributors y: 86 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/WebhookPushRequest.java x: 24 # contributors y: 201 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/HTTPClientPool.java x: 22 # contributors y: 101 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventMeshRebalanceImpl.java x: 4 # contributors y: 217 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/ClientAckContext.java x: 21 # contributors y: 89 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/trace/Trace.java x: 15 # contributors y: 166 lines of code eventmesh-connectors/eventmesh-connector-jdbc/src/main/antlr/MySqlLexer.g4 x: 1 # contributors y: 1262 lines of code eventmesh-connectors/eventmesh-connector-jdbc/src/main/antlr/MySqlParser.g4 x: 1 # contributors y: 2411 lines of code eventmesh-storage-plugin/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/producer/ProducerImpl.java x: 12 # contributors y: 92 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/cloudevents/PublisherServiceGrpc.java x: 3 # contributors y: 453 lines of code eventmesh-sdks/eventmesh-sdk-go/grpc/proto/eventmesh-client.pb.go x: 1 # contributors y: 1271 lines of code eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventmeshRebalanceImpl.java x: 19 # contributors y: 217 lines of code eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/producer/StandaloneProducer.java x: 5 # contributors y: 98 lines of code eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/message/PushMessageRequestBody.java x: 13 # contributors y: 96 lines of code eventmesh-examples/src/main/java/org/apache/eventmesh/selector/NacosSelector.java x: 18 # contributors y: 41 lines of code
8057.0
lines of code
  min: 2.0
  average: 75.15
  25th percentile: 12.0
  median: 29.0
  75th percentile: 69.0
  max: 8057.0
0 47.0
# contributors
min: 1.0 | average: 4.63 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 5.0 | max: 47.0