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 
8.7K
lines of main code
114 files
1.8K
lines of test code
30 files
0.5K
lines of other code
2 files
7y
age
2,603 days
33%
main code touched
1 year (2.9K LOC)
1%
new main code
1 year (117 LOC)
8.4K
java
0.3K
xml

1

3

5

39

32

4

16

3

1

1

5

13

8

4

10

2

2025 2024 2023 2022 2021 2020 2019 2018

generated by sokrates.dev (configuration) on 2025-05-07