Skip to content

[Enhancement] RebalanceImpl's method lockBatchMQ Add Timeout Configuration #7211

@weihubeats

Description

@weihubeats

Before Creating the Enhancement Request

  • I have confirmed that this should be classified as an enhancement rather than a bug/feature.

Summary

I think the timeoutMillis parameter in RebalanceImpl's method lockBatchMQ should be configurable, because the written 1000ms timeout is very forgiving, and then the sequential consumption of messages is often disconnected and reconnected when clientCloseSocketIfTimeout is true by default!
image

Motivation

Prevent frequent disconnection and reconnection of sequential messages

Describe the Solution You'd Like

MQClientAPIImpl lockBatchMQ Add Timeout Configuration

Describe Alternatives You've Considered

no

Additional Context

No response

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions