The Wayback Machine - http://web.archive.org/web/20220409063329/https://github.com/topics/rocketmq
Skip to content
#

rocketmq

Star

Here are 281 public repositories matching this topic...

Language: All
Filter by language
All 281 Java 183 Go 17 Shell 14 JavaScript 11 C++ 8 Python 5 C# 3 Dockerfile 2 SCSS 2 Vue 2
Sort: Best match
Sort options
Best match Most stars Fewest stars Most forks Fewest forks Recently updated Least recently updated

alibaba / spring-cloud-alibaba

Star 21.9k
Open

spring-cloud-starter-stream-rocketmq 2.2.7.RELEASE 版本手动ack后无法同步确认offset

5
xiaowenyu
xiaowenyu commented Mar 1, 2022

组件：
spring-cloud-starter-stream-rocketmq
问题版本：
2.2.7.RELEASE; 2021.0.1.0

问题详情：
stream-rocketmq 2.2.6.RELEASE 升级到 2.2.7.RELEASE 后，无法正常conmit offset

重现步骤：
1.运行的demo如下，使用 AcknowledgmentCallback.noAutoAck() 关闭自动ack，打印之后再 ack

 @Bean
    public ApplicationRunner poller(PollableMessageSource dest1In) {
        return args -> {
            while (true) {
                if (!dest1In.
Read more
good first issue rocketmq contribution welcome kind / bug
Find more good first issues
flink-learning

zhisheng17 / flink-learning

Star 12k

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

mysql redis elasticsearch streaming kafka spark influxdb rabbitmq clickhouse hbase stream-processing opentsdb loki flink rocketmq
  • Updated Mar 23, 2022
  • Java

apache / rocketmq-externals

Star 4.1k

matevip / matecloud

Star 893

🔥MateCloud是一款基于Spring Cloud Alibaba的微服务架构。目前已经整合Spring Boot 2.6、 Spring Cloud 2021、Spring Cloud Alibaba 2021、Spring Security Oauth2、Feign、Dubbo、JetCache、RocketMQ等，支持多租户的低代码平台，Saas平台开发套件

spring-boot microservice spring-cloud saas rbac microservices-architecture spring-security-oauth2 tenant rocketmq springcloud alibabacloud vue3 nacos spring-cloud-alibaba springboot-admin jetcache nacos-spring-cloud springcloudalibaba springboot-springcloud cloudspring
  • Updated Apr 8, 2022
  • Java

apache / dubbo-go-pixiu

Star 319
Open

Add Fault injection filter

mark4z
mark4z commented Dec 24, 2021

What would you like to be added:
A Fault injection filter should provide configurable error injection capabilities, such as delay, error local reply. it is best to have more detailed routing-based configuration capabilities

Why is this needed:
Because this is the ability that is required in the testing phas

Read more
good first issue

Improve this page

Add a description, image, and links to the rocketmq topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the rocketmq topic, visit your repo's landing page and select "manage topics."

Learn more