apache / rocketmq-flink
RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
GitHub Repo
8K
lines of main code
108 files
1.7K
lines of test code
29 files
525
lines of other code
2 files
96%
main code touched
1 year (7.7K LOC)
96%
new main code
1 year (7.7K LOC)
1
recent contributors
past 30 days
5y
age
1,968 days
7.7K
java
273
xml

travis
maven


Main Code: 8,007 LOC (108 files) = JAVA (96%) + XML (3%)
Secondary code: Test: 1,657 LOC (29); Generated: 0 LOC (0); Build & Deploy: 315 LOC (1); Other: 210 LOC (1);
Duplication: 10%
File Size: 0% long (>1000 LOC), 59% short (<= 200 LOC)
Unit Size: 2% long (>100 LOC), 53% short (<= 10 LOC)
Conditional Complexity: 1% complex (McCabe index > 50), 74% simple (McCabe index <= 5)
Logical Component Decomposition: primary (2 components)

5 years, 4 months old

  • 3% of code older than 365 days
  • 3% of code not updated in the past 365 days

0% of code updated more than 50 times

Also see temporal dependencies for files frequently changed in same commits.
Goals: Keep the system simple and easy to change (4)
Straight_Line
Features of interest:
TODOs
2 files

generated by sokrates.dev (configuration) on 2023-08-11; reference date: 2023-08-08