Skip to content

resetOffsetByTimestampOld topicRouteMap maintain the error relationship #3673

@LvChenhui

Description

@LvChenhui

when we use method resetOffsetByTimestampMillis to reset offset,at the same time,our consumer not online,actual use method resetOffsetByTimestampOld. topicRouteMap store the relationship between brokerAddr and readQueueNums,but
in the following code,the latter readQueueNumber will cover the former.

TopicRouteData topicRouteData = this.examineTopicRouteInfo(topic);
        List<RollbackStats> rollbackStatsList = new ArrayList<RollbackStats>();
        Map<String, Integer> topicRouteMap = new HashMap<String, Integer>();
        for (BrokerData bd : topicRouteData.getBrokerDatas()) {
            for (QueueData queueData : topicRouteData.getQueueDatas()) {
                topicRouteMap.put(bd.selectBrokerAddr(), queueData.getReadQueueNums());
            }
        }

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions