Skip to content

Conversation

DongyuanPan
Copy link
Contributor

@DongyuanPan DongyuanPan commented Sep 28, 2022

What is the purpose of the change

close #5200
In RocketMQ 4.9.3,the interface updateConsumerOffset does not check whether the topic exists or not. But in RocketMQ 5.0 do the check. LMQ's topic will not register to namesv, so it will throw error when save offset in rocketmq-mqtt.

apache/rocketmq-mqtt#150

Brief changelog

add containsTopic interface in TopicConfigManager, when enable lmq it will use LmqTopicConfigManager#containsTopic which process LMQ Topic

@ShannonDing
Copy link
Member

hi, it's better to create an issue first.

@ShannonDing ShannonDing changed the title bugfix: compatible rocketmq-mqtt save offset [ISSUE #5214] compatible rocketmq-mqtt save offset Sep 28, 2022
@ShannonDing ShannonDing linked an issue Sep 28, 2022 that may be closed by this pull request
Copy link
Contributor

@caigy caigy left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@lizhanhui lizhanhui merged commit cf6ed4d into apache:develop Sep 29, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

5 participants