[Bug] Lite-selective consumer groups are reported as CLUSTERING by the Proxy Admin surface

Đang mở
  • Có gì không ổn?
#11,371 1 bình luận 0 reaction 0 người được giao Xem trên GitHub

Maintainer thường phản hồi trong vòng 1 ngày

@iloveeyjafjalla đang làm issue này rồi.

Từ ngày 12/10/2026.

  • #11372 của @iloveeyjafjalla — đang mở

Đánh giá

Độ khó
2/5
Thời gian dự kiến
1-3 giờ
Mức phù hợp với người mới
25/100
Loại issue
Lỗi
Độ rõ ràng
Đặc tả rõ ràng
Mức độ hoạt động
Đình trệ
Công nghệ
java
Lĩnh vực
backend, distributed-systems

Hướng nghiên cứu

Start with the message model converter used by ListSubscription, DescribeSubscription, and ListConsumerConnection, then inspect the existing tests for those admin responses. Confirm the returned message_model for a lite consumer group is LITE_SELECTIVE. An open pull request, #11372, is already linked to this issue.

Do mô hình lập chỉ mục viết ra từ nội dung của issue.

Mô tả

Before Creating the Bug Report
  • I found a bug, not just asking a question, which should be created in GitHub Discussions.
  • I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.
  • I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.
Runtime platform environment

OS: any (proxy module, admin gRPC surface; needs a consumer group of lite consumers)

RocketMQ version

branch: develop
Git commit id: 9ea2ccdc2b41445aee5e177e14e501d606f5a1ed (2026-10-08)

JDK Version

Compiler: Temurin 1.8.0_504 (target 1.8, same as CI)

Describe the Bug

Groups of lite consumers are reported as CLUSTERING by the admin surface, although the proto has a dedicated
consumption model for them.

The proxy produces MessageModel.LITE_SELECTIVE for lite consumers (ClientActivity#buildMessageModel returns it for
LITE_PUSH_CONSUMER / LITE_SIMPLE_CONSUMER), and the admin proto defines the matching value:

// Consumers of the group selectively subscribe to individual lite topics
// that are multiplexed onto a shared physical topic.
LITE_SELECTIVE = 3;

but the converter drops it:

switch (messageModel) {
    case BROADCASTING:
        return apache.rocketmq.v2.MessageModel.BROADCASTING;
    case CLUSTERING:
    default:
        return apache.rocketmq.v2.MessageModel.CLUSTERING;
}

LITE_SELECTIVE therefore falls into default and every ListSubscription / DescribeSubscription /
ListConsumerConnection answer reports a lite-selective group as an ordinary clustering group, so a console cannot tell
the two apart — even though the model is known and expressible.

Steps to Reproduce
  1. Run a proxy with grpcAdminServerEnable=true and a group whose consumers are lite consumers
    (ClientType.LITE_PUSH_CONSUMER / LITE_SIMPLE_CONSUMER).
  2. Call ListSubscription{group} (or DescribeSubscription / ListConsumerConnection).
  3. The returned subscription_info[].message_model is CLUSTERING.
Expected behavior

message_model is LITE_SELECTIVE for such a group.

Actual behavior

CLUSTERING.

Additional context

Note this is a different path from the wildcard-lite consumption-model work: the converter change only affects groups
the proxy already classifies as LITE_SELECTIVE, and leaves BROADCASTING / CLUSTERING / unknown values untouched.

Ngôn ngữ chính
Java
Star
22.7k
Fork
12k
Merge trung bình
3 ngày 18 giờ
Pull request đã merge (30 ngày)
17

Chuẩn bị môi trường

Bắt đầu từ đâu

  1. Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
  2. Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
  3. Fork repository và làm thay đổi trên một nhánh.
  4. Mở pull request có tham chiếu số hiệu của issue.

Issue khác của apache/rocketmq

Tất cả issue của apache/rocketmq

Issue tương tự

Thêm issue về Java

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.