from apache #2

francisoliverlee · 2023-04-25T05:44:04Z

What is the purpose of the change

XXXXX

Brief changelog

XX

Verifying this change

XXXX

Follow this checklist to help us incorporate your contribution quickly and easily. Notice, it would be helpful if you could finish the following 5 checklist(the last one is not necessary)before request the community to review your PR.

Make sure there is a Github issue filed for the change (usually before you start working on it). Trivial changes like typos do not require a Github issue. Your pull request should address just this issue, without pulling in other changes - one PR resolves one issue.
Format the pull request title like [ISSUE #123] Fix UnknownException when host config not exist. Each commit in the pull request should have a meaningful subject line and body.
Write a pull request description that is detailed enough to understand what the pull request does, how, and why.
Write necessary unit-test(over 80% coverage) to verify your logic correction, more mock a little better when a cross-module dependency exists.
If this contribution is large, please file an Apache Individual Contributor License Agreement.

…sage processing

* Refactor the client instance struct，converge the namesrv module * fix the feature that GetNamesrv(clientId)

Signed-off-by: zhangyang <[email protected]>

…et ops when remote endpoint crash. 2. enable tcp keep alive.

2. change default read/write Deadline to 120 sec. 3. close connection when set deadline fail.

fix long time block when remote endpoint crash.

[ISSUE #818] fix msg.Body compressed cause error in transaction message processing

fix queueMaxSpanFlowControlTimes not change

[ISSUE #828] Support rlog rotate

[ISSUE #827] Support get consumerRunningInfo return goroutine stack

fix some params for consumer can not be changed

[ISSUE #810] fix async producer example

* [Issue #778] Build instance name with nanosecond (#779) [Issue #778] Build instance name with nanosecond (#779) * Merge remote-tracking branch 'origin/master' * Merge remote-tracking branch 'origin/master' * feat: request reply producer * feat: update * feat: add consumer * feat: fix ci * feat: update * feat: update * feat: 修改request请求参数 * feat: modify async request for delete * feat: fix go1.11 and go1.12 don't have time.Millseconds * feat: move time.Millisecond() to duration/time.Millisecond * feat: fix async request not remove requestResponseFutrue Co-authored-by: chaiyx <[email protected]> Co-authored-by: Administrator <[email protected]> Co-authored-by: haohongfan1 <[email protected]> Co-authored-by: dinglei <[email protected]>

Co-authored-by: chenhui <[email protected]>

* fix: panic problem caused by json-iterator * fix: keep go version in 1.13 Co-authored-by: yushan <[email protected]>

…d in resume

Co-authored-by: huwen.alvin <[email protected]>

bugfix rebalance is not paused after suspend and rebalance not trigge…

Co-authored-by: chaos <[email protected]>

Co-authored-by: jack.wong <[email protected]>

Co-authored-by: wuxb02 <[email protected]>

* fix limiter with goroutine cover * fix limiter with goroutine cover Co-authored-by: 鲁扬 <[email protected]>

Co-authored-by: 筱瑜 <[email protected]>

Co-authored-by: dengzhiwen1 <[email protected]>

[ISSUE #986]Reduce the log level when fetch offset success and remove unnecessary mq

…ocess send resp error (#997)

Co-authored-by: shuai.qi <[email protected]>

[ISSUE #999]support admin topicList and groupList method

[ISSUE #1002] fix: add log when send heartbeat failed

[ISSUE #994] Fix: unlock all queues when consumer shutdown in orderly model

Replacing github.com/satori/go.uuid with github.com/google/uuid

* seperate interface and implement * fix panic when close tracedispatcher * Restore rlog/log.go * Delete default.go

…ame) [ISSUE #989] consumer and producer client add unit support (WithUnitName)

fix typo

trxo and others added 30 commits June 16, 2021 22:55

fix msg.Body compressed and not reset, cause error in transaction mes…

847c11d

…sage processing

Fix the feature that GetNamesrv (#805)

b7a7911

* Refactor the client instance struct，converge the namesrv module * fix the feature that GetNamesrv(clientId)

[ISSUE #807] fix code style (#808)

7cd7fa9

Signed-off-by: zhangyang <[email protected]>

fix async producer example

2d8ce82

1. add tcp conn write and read deadline to avoid long time block sock…

b3ce4dc

…et ops when remote endpoint crash. 2. enable tcp keep alive.

1. remove request from responseTable when sendAsync

f1913d6

2. change default read/write Deadline to 120 sec. 3. close connection when set deadline fail.

1. add log when close socket.

9ebb5ba

1. make tcp relate param configurable

55b7717

1. fix ci

b140046

Merge branch 'master' of github.com:apache/rocketmq-client-go

5cef32e

Merge pull request #816 from WJL3333/fix_tcp_write_block

40242bc

fix long time block when remote endpoint crash.

Merge pull request #679 from trxo/master

853f304

[ISSUE #818] fix msg.Body compressed cause error in transaction message processing

fix queueMaxSpanFlowControlTimes not change

449e940

Merge pull request #824 from cserwen/fix_flow

0189e44

fix queueMaxSpanFlowControlTimes not change

fix some params for consumer can not be changed

3d2cd25

1. support get consumerRunningInfo return goroutine stack

b815a70

1. support rlog rotate

7bc7af5

Merge pull request #829 from WJL3333/support_log_rotate

2d7d781

[ISSUE #828] Support rlog rotate

Merge pull request #826 from WJL3333/support_goroutine_stack

12ce1b9

[ISSUE #827] Support get consumerRunningInfo return goroutine stack

Merge pull request #825 from cserwen/consumer_option

6132b34

fix some params for consumer can not be changed

Merge pull request #809 from yuz10/master

1f541f7

[ISSUE #810] fix async producer example

[ISSUE #832] Client may submit wrong offset when network instability

16443e2

Co-authored-by: chenhui <[email protected]>

[ISSUE #823]fix: panic problem caused by json-iterator in go1.18 (#841)

d86140d

* fix: panic problem caused by json-iterator * fix: keep go version in 1.13 Co-authored-by: yushan <[email protected]>

bugfix rebalance is not paused after suspend and rebalance not trigge…

3d93e29

…d in resume

fix(sendOneWay): fix stack overflow caused by recursive calls (#773)

26e13b7

Co-authored-by: huwen.alvin <[email protected]>

Merge pull request #852 from NeonToo/fix/reset_offset

ade7cfa

bugfix rebalance is not paused after suspend and rebalance not trigge…

1. avoid cancel context too early cause trace data fail.

35b951d

fix: selectMessageQueue nil *internal.TopicPublishInfo

88b1b05

feat: exchange messages_utils dir

a4143a1

weavernet and others added 29 commits October 22, 2022 21:40

[ISSUE #942] fix some spell mistakes (#949)

620cf96

Co-authored-by: chaos <[email protected]>

[ISSUE #942] Fix response ResQueryNotFound typo (#948)

5779439

Co-authored-by: jack.wong <[email protected]>

[ISSUE #931] fix filter message (#932)

c197b50

Co-authored-by: wuxb02 <[email protected]>

[ISSUE #927] fix processQueue remove offset (#928)

8afd69f

Co-authored-by: wuxb02 <[email protected]>

[ISSUE #953] fix limiter with goroutine cover (#952)

96f00c4

* fix limiter with goroutine cover * fix limiter with goroutine cover Co-authored-by: 鲁扬 <[email protected]>

[ISSUE #956]fix reset offset remove pq (#957)

6bbfc3f

push consumer enable getting offset diff map (#964)

0742aac

Co-authored-by: 筱瑜 <[email protected]>

add api GetOffsetDiffMap (#965)

cad2f66

Co-authored-by: 筱瑜 <[email protected]>

fix: data race when update subversion for consumer (#962)

f56a2db

Co-authored-by: dengzhiwen1 <[email protected]>

change uuid to google/uuid

12740f0

[ISSUE #975]when close consumer, return directly

896a8a3

reduce the log level when fetch offset success and remove unnecessary mq

cfb845b

Merge pull request #987 from humkum/reduce-log-level

757e639

[ISSUE #986]Reduce the log level when fetch offset success and remove unnecessary mq

fix:logic error when reset retry message's origin topic (#971)

a2cf953

[ISSUE #999]support admin topicList and groupList method

daacb8e

[ISSUE #996] invoke user callback and return error info when async pr…

c8d06a6

…ocess send resp error (#997)

fix: add log when send heartbeat failed

df5be5b

fix: client version mismatch (#1009)

26142da

Co-authored-by: shuai.qi <[email protected]>

[ISSUE #999] fix npe

62d4513

[ISSUE #999] use structs as result sets for admin method

c133cca

[ISSUE #999] add timeoutMillis param

caca3c0

Merge pull request #1000 from Slideee/20230213/rmq

ae93d2a

[ISSUE #999]support admin topicList and groupList method

fix: unlock all queues when consumer shutdown in orderly model

9bca88d

Merge pull request #1003 from cserwen/heartbeat_github

56d1a7d

[ISSUE #1002] fix: add log when send heartbeat failed

Merge pull request #1015 from cserwen/orderly_consume_github

3b8b238

[ISSUE #994] Fix: unlock all queues when consumer shutdown in orderly model

Merge pull request #972 from BLAZZ/master

6c77b67

Replacing github.com/satori/go.uuid with github.com/google/uuid

fix Panic when close traceDispatcher (#1027)

7ae788d

* seperate interface and implement * fix panic when close tracedispatcher * Restore rlog/log.go * Delete default.go

[ISSUE #989] consumer and producer client add unit support (WithUnitN…

7f3ffe2

…ame) [ISSUE #989] consumer and producer client add unit support (WithUnitName)

Update README.md (#1026)

25003f6

fix typo

francisoliverlee merged commit 9657798 into francisoliverlee:master Apr 25, 2023

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

from apache #2

from apache #2

francisoliverlee commented Apr 25, 2023

from apache #2

from apache #2

Conversation

francisoliverlee commented Apr 25, 2023

What is the purpose of the change

Brief changelog

Verifying this change