Home / apache / rocketmq
Repository Analysis

apache/rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.

0.6 Likely human-written View on GitHub
0.6
Adjusted Score
0.6
Raw Score
100%
Time Factor
2026-05-29
Last Push
22,439
Stars
Java
Language
400,055
Lines of Code
2415
Files
80
Pattern Hits
2026-05-31
Scan Date

Score History

Severity Breakdown

CRITICAL 15HIGH 0MEDIUM 16LOW 49

Pattern Findings

80 matches across 8 categories. Click a row to expand file-level details.

Hallucination Indicators15 hits · 150 pts
SeverityFileLineSnippet
CRITICAL…va/org/apache/rocketmq/remoting/netty/NettyLogger.java36 io.netty.util.internal.logging.InternalLoggerFactory.setDefaultFactory(new NettyBridgeLoggerFactory());
CRITICAL…/broker/config/v1/RocksDBSubscriptionGroupManager.java318 if (!org.apache.rocketmq.common.UtilAll.isPathExists(separateRocksDBPath)) {
CRITICAL…he/rocketmq/proxy/grpc/v2/route/RouteActivityTest.java82 addressArrayList.add(new org.apache.rocketmq.proxy.common.Address(
CRITICAL…he/rocketmq/proxy/grpc/v2/route/RouteActivityTest.java85 addressArrayList.add(new org.apache.rocketmq.proxy.common.Address(
CRITICAL…cketmq/proxy/grpc/v2/producer/SendMessageActivity.java201 org.apache.rocketmq.common.message.Message messageWithHeader = new org.apache.rocketmq.common.message.Message();
CRITICAL…apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java199 addressList.add(new org.apache.rocketmq.proxy.common.Address(
CRITICAL…apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java200 org.apache.rocketmq.proxy.common.Address.AddressScheme.valueOf(endpoints.getScheme().name()),
CRITICAL…/java/org/apache/rocketmq/test/grpc/v2/GrpcBaseIT.java574 org.apache.rocketmq.common.message.MessageQueue dlqMQ = new org.apache.rocketmq.common.message.MessageQueue(MixA
CRITICAL…/rocketmq/test/clientinterface/AbstractMQProducer.java101 org.apache.rocketmq.common.message.Message msg = new org.apache.rocketmq.common.message.Message(
CRITICAL…on/builder/DefaultAuthorizationContextBuilderTest.java518 lockMqSet.add(new org.apache.rocketmq.common.message.MessageQueue("topic", "broker-a", 0));
CRITICAL…on/builder/DefaultAuthorizationContextBuilderTest.java520 lockMqSet.add(new org.apache.rocketmq.common.message.MessageQueue("%RETRY%group", "broker-a", 1));
CRITICAL…on/builder/DefaultAuthorizationContextBuilderTest.java547 unlockMqSet.add(new org.apache.rocketmq.common.message.MessageQueue("topic", "broker-a", 0));
CRITICAL…on/builder/DefaultAuthorizationContextBuilderTest.java549 unlockMqSet.add(new org.apache.rocketmq.common.message.MessageQueue("%RETRY%group", "broker-a", 1));
CRITICAL…main/java/io/openmessaging/rocketmq/utils/OMSUtil.java48 org.apache.rocketmq.common.message.Message rmqMessage = new org.apache.rocketmq.common.message.Message();
CRITICAL…q/tieredstore/core/MessageStoreDispatcherImplTest.java109 Mockito.when(messageStore.getMessageStoreConfig()).thenReturn(new org.apache.rocketmq.store.config.MessageStoreC
Over-Commented Block40 hits · 40 pts
SeverityFileLineSnippet
LOW.asf.yaml1# Licensed to the Apache Software Foundation (ASF) under one or more
LOWCONTRIBUTING.md41
LOW.licenserc.yaml1#
LOW…he/rocketmq/tools/admin/DefaultMQAdminExtImplTest.java641 }
LOW…esrv/routeinfo/RouteInfoManagerBrokerRegisterTest.java61 }
LOWdistribution/benchmark/consumer.sh1#!/bin/sh
LOWdistribution/benchmark/runclass.sh1#!/bin/sh
LOWdistribution/benchmark/tproducer.sh1#!/bin/sh
LOWdistribution/benchmark/batchproducer.sh1#!/bin/sh
LOWdistribution/benchmark/producer.sh1#!/bin/sh
LOWdistribution/benchmark/shutdown.sh1#!/bin/sh
LOWdistribution/bin/runserver.sh1#!/bin/sh
LOWdistribution/bin/cleancache.sh1#!/bin/sh
LOWdistribution/bin/tools.sh1#!/bin/sh
LOWdistribution/bin/runbroker.sh1#!/bin/sh
LOWdistribution/bin/cleancache.v1.sh1#!/bin/sh
LOWdistribution/bin/setcache.sh1#!/bin/sh
LOWdistribution/bin/export.sh1#!/bin/bash
LOWdistribution/bin/cachedog.sh1#!/bin/sh
LOWdistribution/bin/startfsrv.sh1#!/bin/sh
LOWdistribution/bin/play.sh1#!/bin/sh
LOWdistribution/bin/os.sh1#!/bin/sh
LOW…tion/bin/controller/fast-try-independent-deployment.sh1#!/usr/bin/env bash
LOWdistribution/bin/controller/fast-try-namesrv-plugin.sh1#!/usr/bin/env bash
LOWdistribution/bin/controller/fast-try.sh1#!/usr/bin/env bash
LOWdistribution/bin/dledger/fast-try.sh1#!/usr/bin/env bash
LOWdistribution/conf/tools.yml1# Licensed to the Apache Software Foundation (ASF) under one or more
LOWdocs/cn/Configuration_TLS.md41# The flag to determine whether use test mode when initialize TLS context. default is true
LOW…org/apache/rocketmq/common/message/MessageDecoder.java61// + 4 // 4 QUEUEID
LOW.github/workflows/license-checker.yaml1# Licensed to the Apache Software Foundation (ASF) under one
LOW.github/workflows/snapshot-automation.yml1# Licensed to the Apache Software Foundation (ASF) under one
LOW.github/ISSUE_TEMPLATE/feature_request.yml1#
LOW.github/ISSUE_TEMPLATE/bug_report.yml1#
LOW.github/ISSUE_TEMPLATE/config.yml1#
LOW.github/ISSUE_TEMPLATE/enhancement_request.yml1#
LOW.github/ISSUE_TEMPLATE/doc.yml1#
LOWdev/merge_rocketmq_pr.py1#!/usr/bin/env python
LOWclient/src/test/resources/acl_hook/plain_acl.yml1# Licensed to the Apache Software Foundation (ASF) under one or more
LOWclient/src/test/resources/conf/plain_acl_incomplete.yml1# Licensed to the Apache Software Foundation (ASF) under one or more
LOW…ache/rocketmq/store/queue/BatchConsumeMessageTest.java81 @Test
Decorative Section Separators12 hits · 36 pts
SeverityFileLineSnippet
MEDIUMdistribution/bin/runserver.sh18#===========================================================================================
MEDIUMdistribution/bin/runserver.sh20#===========================================================================================
MEDIUMdistribution/bin/runserver.sh53#===========================================================================================
MEDIUMdistribution/bin/runserver.sh55#===========================================================================================
MEDIUMdistribution/bin/tools.sh18#===========================================================================================
MEDIUMdistribution/bin/tools.sh20#===========================================================================================
MEDIUMdistribution/bin/tools.sh53#===========================================================================================
MEDIUMdistribution/bin/tools.sh55#===========================================================================================
MEDIUMdistribution/bin/runbroker.sh18#===========================================================================================
MEDIUMdistribution/bin/runbroker.sh20#===========================================================================================
MEDIUMdistribution/bin/runbroker.sh53#===========================================================================================
MEDIUMdistribution/bin/runbroker.sh55#===========================================================================================
Excessive Try-Catch Wrapping8 hits · 11 pts
SeverityFileLineSnippet
MEDIUM…tools/command/metadata/RocksDBConfigToJsonCommand.java238 System.out.print("Error occurred while converting RocksDB kv config to json, " + "configType=" + configType
MEDIUM…tools/command/metadata/RocksDBConfigToJsonCommand.java323 System.out.print("Error occurred while converting RocksDB kv config to json, " + "configType=consumerOffsets
LOWdev/merge_rocketmq_pr.py127 except Exception as e:
LOWdev/merge_rocketmq_pr.py175 except Exception as e:
LOWdev/merge_rocketmq_pr.py198 except Exception as e:
LOWdev/merge_rocketmq_pr.py209 except Exception as e:
LOWdev/merge_rocketmq_pr.py240 except Exception as e:
MEDIUMdev/merge_rocketmq_pr.py69def get_json(url):
Verbosity Indicators2 hits · 3 pts
SeverityFileLineSnippet
LOW…rocketmq/broker/lite/LiteSubscriptionRegistryImpl.java450 // Step 1: Find expired clients and their subscription information
LOW…rocketmq/broker/lite/LiteSubscriptionRegistryImpl.java457 // Step 2: Remove expired clients and their subscriptions
AI Slop Vocabulary1 hit · 3 pts
SeverityFileLineSnippet
MEDIUM…rocketmq/broker/processor/PopLiteMessageProcessor.java163 // we no longer utilize startOffset and msgOffset
Slop Phrases1 hit · 2 pts
SeverityFileLineSnippet
LOW…/apache/rocketmq/example/filter/SqlFilterConsumer.java34 // Don't forget to set enablePropertyFilter=true in broker
Hyper-Verbose Identifiers1 hit · 1 pts
SeverityFileLineSnippet
LOW…/proxy/service/transaction/TransactionDataManager.java37public class TransactionDataManager implements StartAndShutdown {