Hacktoberfest 2026：メンテナが10月に向けて印を付けた、オープンで初心者向けの issue。 Hacktoberfest の issue を見る

RocketMQ 5.0 client messageGroup not online

オープン
  • 何か問題がありますか？
#737 コメント 2 件 リアクション 0 件 担当者 0 名 GitHub で見る

まだ誰も着手していません。

評価

難易度
3/5
見積もり時間
1〜2日
初心者へのやさしさ
48/100
issue の種類
バグ
明瞭さ
説明が足りない
活発さ
静か
技術スタック
java, spring-boot
領域
backend, distributed-systems

調査の方向性

提供された producer と consumer の例で、rocketmq-spring-boot-starter の設定、@RocketMQMessageListener の使用、および MessageView.getMessageGroup から始めます。NormalTopic のフローを再現し、starter の変更前後で受信した MessageView とコンソールの状態を比較します。messageGroup が空であるにもかかわらず消費に成功する理由を説明または修正できれば完了です。

索引モデルが issue の本文から書いたものです。

説明

启动日志

2025-07-20 02:41:31.898 [main] INFO o.a.r.c.a.ListenerContainerConfiguration - Register the listener to container, listenerBeanName:normalTopicConsumer, containerBeanName:org.apache.rocketmq.client.support.DefaultListenerContainer_3
2025-07-20 02:41:33.304 [main] INFO o.a.r.c.s.DefaultListenerContainer - running container: DefaultListenerContainer{name='org.apache.rocketmq.client.support.DefaultListenerContainer_3', running=true, accessKey='', secretKey='', endpoints='192.168.2.177:8081', consumerGroup='springboot_consumer_group_normal', tag='*', topic='NormalTopic', type='tag', filterExpressionType=null, requestTimeout=PT3S, maxCachedMessageCount=1024, maxCacheMessageSizeInBytes=67108864, consumptionThreadCount=20, namespace=''}
2025-07-20 02:41:33.337 [main] INFO org.example.cloud.CloudApplication - Started CloudApplication in 4.123 seconds (process running for 4.814)

rocketmq:
  producer:
    endpoints: 192.168.2.177:8081
  tag: "*"
  topics:
    normal: NormalTopic
    
  consumer:
    groups:
      normal: springboot_consumer_group_normal
      


//生产者
 Message<String> message = MessageBuilder.withPayload("sync").build();
        SendReceipt sendReceipt = rocketMQClientTemplate.syncSendNormalMessage(normalTopic, message);
        log.info("普通消息发送成功,sendReceipt:{}", sendReceipt);
        return sendReceipt;

//消费者
@Slf4j
@Service
@RocketMQMessageListener(endpoints = "${rocketmq.producer.endpoints}", topic = "${rocketmq.topics.normal}", consumerGroup = "${rocketmq.consumer.groups.normal}", tag = "${rocketmq.tag}")
public  class NormalTopicConsumer implements RocketMQListener {

    @Override
    public ConsumeResult consume(MessageView messageView) {
        log.info("NormalTopicConsumer,接收成功:{}", messageView);
        log.info("body,接收成功:{}", messageView.getBody());
        log.info("group,接收成功:{}", messageView.getMessageGroup());


        return ConsumeResult.SUCCESS;
    }
}

2025-07-20 02:30:45.503 [http-nio-7888-exec-1] INFO o.e.c.r.s.ProducerController - 普通消息发送成功,sendReceipt:SendReceiptImpl{messageId=0100155D939C9A3C18088D7E5500000000}
2025-07-20 02:30:45.511 [RocketmqMessageConsumption-2-78] INFO o.e.c.r.s.c.NormalTopicConsumer - NormalTopicConsumer,接收成功:MessageViewImpl{messageId=0100155D939C9A3C18088D7E5500000000, topic=NormalTopic, bornHost=DESKTOP-VSOC5FB, bornTimestamp=1752949845410, endpoints=ipv4:192.168.2.177:8081, deliveryAttempt=1, tag=null, keys=[], messageGroup=null, deliveryTimestamp=null, properties={id=081dd3ee-ae98-f656-e0eb-241d73ae36d6, contentType=text/plain;charset=UTF-8, timestamp=1752949845354}}
2025-07-20 02:30:45.511 [RocketmqMessageConsumption-2-78] INFO o.e.c.r.s.c.NormalTopicConsumer - body,接收成功:java.nio.HeapByteBufferR[pos=0 lim=4 cap=4]
2025-07-20 02:30:45.511 [RocketmqMessageConsumption-2-78] INFO o.e.c.r.s.c.NormalTopicConsumer - group,接收成功:Optional.empty

接收成功但是日志显示messageGroup=null
group为空，为什么控制台还能打印NormalTopicConsumer,接收成功:MessageViewImpl{messageId=0100155D939C9A3C18088D7E5500000000.....

换rocketmq-spring-boot-starter状态变成CONSUMED

Image
主要言語
Java
スター
2.3k
フォーク
941
30日以内にマージされた PR はありません

環境構築

  • Dockerfile・Docker Compose ファイルなし
  • プルリクエストのテンプレートあり
  • コントリビューションガイドなし

はじめの一歩

  1. issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
  2. 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
  3. リポジトリをフォークし、ブランチを切って変更します。
  4. issue 番号を参照したプルリクエストを送ります。

apache/rocketmq-spring のほかの issue

apache/rocketmq-spring の issue をすべて見る

似ている issue

Java の issue をもっと見る

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。