Skip to content

[ci-run][fix][broker]Can't consume messages for a long time due to Entry Filter#8

Closed
poorbarcode wants to merge 29 commits intomasterfrom
flaky/FilterEntryTest.java
Closed

[ci-run][fix][broker]Can't consume messages for a long time due to Entry Filter#8
poorbarcode wants to merge 29 commits intomasterfrom
flaky/FilterEntryTest.java

Conversation

@poorbarcode
Copy link
Owner

@poorbarcode poorbarcode commented Sep 21, 2022

@poorbarcode poorbarcode force-pushed the flaky/FilterEntryTest.java branch from 3e48f88 to 2bb0869 Compare September 30, 2022 08:16
poorbarcode and others added 17 commits September 30, 2022 17:32
…apache#17893)

Fixes: apache#16864

### Motivation

I think it is a wrong configuration(`ackTimeout 1s`) when writing the code, the original design is set `negativeAckRedeliveryDelay 1s`

The process expects:

- send 10 messages in one batch
  - submit a batch. 
- receive 10 messages, do negative acknowledge
- after `1s`, will trigger `redelivery`
- receive 10 messages again

The real process:
- send 1 message
  - Reach the batch time limit, and submit a batch. return `msgId_1`
- send 9 messages in another batch
  - submit a batch. return `msgId_2`
- receive 10 messages, do negative acknowledge
  - push the `msgId_1` to `negativeAcksTracker`
  - push the `msgId_2` to `unAckedMessageTracker`
- after `1s`, will trigger redelivery `msgId_2` by `unAckedMessageTracker`
- receive 9 messages( `msgId_2` ) again
- after `60s`, will trigger redelivery `msgId_1` by `negativeAcksTracker`. <strong>(High light)</strong> Test execution timeout!
- receive 1 messages( `msgId_1` ) again



### Modifications

- remove conf: `ackTimeout`
- set `negativeAckRedeliveryDelay 1s`


### Documentation

- [x] `doc-not-needed` 

### Matching PR in forked repository

PR in forked repository: 

- #18
* improve TLS encryption

* fix review comments

* preview fix

* add file and syntax for page redirection

* update the process to create PEM certs

* add more description for mTLS
…he#17855)

* [fix] Remove pulsar-broker-common dependency from pulsar-client

* fix newline

* add enforcer rule

* Move packages-core to jdk8 bytecode

* checkstyle

* use variables

* style

* Fix annotation discovery

* Fix kafka module compile
… options for PerfTool CLI (apache#17862)

* Add proxyServiceUrl and proxyProtocol as oprtions for PerfTool CLI

* Add proxyServiceUrl and proxyProtocol as oprtions for PerfTool CLI

* Add proxyServiceUrl and proxyProtocol as oprtions for PerfTool CLI

* Add proxyServiceUrl and proxyProtocol as oprtions for PerfTool CLI

* Add proxyServiceUrl and proxyProtocol as oprtions for PerfTool CLI

* Add proxyServiceUrl and proxyProtocol as oprtions for PerfTool CLI

* Add proxyServiceUrl and proxyProtocol as oprtions for PerfTool CLI

* Add proxyServiceUrl and proxyProtocol as oprtions for PerfTool CLI

Co-authored-by: Vineeth <vineeth.polamreddy@verizonmedia.com>
@poorbarcode poorbarcode force-pushed the flaky/FilterEntryTest.java branch from 2bb0869 to 8d3986c Compare October 4, 2022 07:35
@github-actions
Copy link

github-actions bot commented Nov 4, 2022

The pr had no activity for 30 days, mark with Stale label.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.