[astubbs]

Description

The review gate has only ever asked whether a machine reviewed the PR. The half that actually decides a merge here — "have I read this one myself yet?" — was carried in your head across a dozen open PRs, and was getting dropped. This adds it as the second half of the same check, so it is visible on the PR instead of remembered.

The gate now asserts two things, and says which one is missing:

Half	Asserted by	Fails with
An automated review exists and finished	bin/check-review-posted.sh (unchanged)	This PR has never been reviewed: claude[bot] ...
The owner has left a human LGTM	bin/check-human-lgtm.sh (new)	NO HUMAN LGTM ON THIS PR ...

Both halves run on every gate run even when the other has already failed, so one look at the checks list tells you everything outstanding rather than only the first thing to go red. The second half is skipped only when the first never ran at all (fork refusal, failed self-test), where a second error would be noise.

The exact matching rule

Canonical home: bin/check-human-lgtm.sh, and only there. docs/ci.md owns the gate contract (both halves must pass); the script owns the matching rule below, because its prose sits beside the awk that implements it and the two cannot drift apart unnoticed. What follows is a description of the change, not a fifth copy to maintain.

A PR satisfies the human half when at least one submitted pull-request review exists such that:

1. Source — it came from repos/<repo>/pulls/<n>/reviews. A review, not an issue comment: "lgtm" typed into the ordinary comment box does not count, and neither does an inline comment on a line of code. The stamp is the thing you press "Submit review" for.
2. Identity — .user.login is astubbs, compared case-insensitively (GitHub logins are unique case-insensitively, so folding cannot admit a second person — and a required check that could brick the repo over a capital letter is worse than the problem it prevents). Taken from the API, never from anything written in a body.
3. Token — the body contains lgtm:
   • case-insensitive — lgtm, LGTM, Lgtm all count;
   • as a whole word — no letter or digit either side, so ALGTM, lgtm2, xLGTM do not match; punctuation either side is fine ((lgtm), LGTM!, -- lgtm);
   • not followed by ? (optionally after spaces) — lgtm? asks, it does not stamp;
   • not immediately preceded by a negator — not, no, never, or an n't contraction — so NOT LGTM, not lgtm, isn't LGTM are refused. Only the word touching it is considered; a general negation detector is unbounded, and half of one firing unpredictably is worse than a rule you can state in a sentence;
   • not inside a fenced code block or a blockquote — a review quoting somebody else's LGTM, or discussing this rule (as any review of this PR must), does not stamp by accident.
4. State is not consulted, except that a PENDING (never-submitted) review is ignored.

Why case-insensitive, and why state is ignored — both decided by looking

I checked the rule against every LGTM this repo has actually received rather than against taste, because a memory aid that rejects the habit it is meant to remind you of is a nuisance people route around.

Corrected. An earlier revision of this description, and of the first commit on the branch, claimed 18 owner LGTMs running from #210 to #292, all of them the lower-case bare word. That was wrong, and had been pasted into four files. The figures below are re-derived from repos/astubbs/parallel-consumer/pulls/<n>/reviews over all 181 PRs. The survey is now stated in one place — bin/check-human-lgtm.sh — and linked from everywhere else.

50 owner LGTM reviews, across 38 PRs, from #63 to #292 — and all 50 are COMMENTED reviews, not approvals. A rule that wanted APPROVED would have gone red on every stamp this repo has ever been given.

Two of them are why the rule is shaped the way it is, and both are now self-test cases:

• Forty-nine spell it lgtm. One — ci: quarantine lane - @Quarantined tag + enforced registry so green checks mean mergeable #84 — is Lgtm. Case-insensitivity is therefore not a courtesy: without it this repo has a stamp on record that the checker would call missing.
• Forty-six are the bare word alone on a line; four carry a trailing clause (lgtm to try on tooling(rename): the package-rename script, and the copyright fix it needs to run #280, and three of the form lgtm, @claude can you take a look please). One of those — build(deps): refresh dependencies + build plugins to latest non-major #73's lgtm, @claude how about you? — ends in a question mark and must still pass, which is why the ? clause rejects only a ? touching the token rather than one anywhere in the body.

Two consequences of "state is not consulted" are load-bearing rather than pedantic:

• An APPROVED review with an empty body does NOT count. The request was for a visible, deliberate word; a silent Approve is exactly the reflex this exists to interrupt.
• A DISMISSED review still DOES count. The master ruleset sets dismiss_stale_reviews_on_push: true, so an approval here is dismissed by the next push. Had the check consulted state, it would have been head-sensitive through the back door — green, then quietly red again after an unrelated typo fix.
• A CHANGES_REQUESTED review saying LGTM counts. A contradiction you wrote about your own PR is not this check's to arbitrate, and unresolved threads block the merge by a separate rule in the same ruleset.

Why it is head-insensitive

An LGTM on any commit of the PR counts for the whole PR, permanently. Two independent reasons:

1. It matches the gate's existing design. The automated half stopped asking about head freshness deliberately (archived at archive/review-gate-strict-head-freshness, reasoning in docs/inflight/parked-strict-review-gate-freshness.md). Two halves of one check disagreeing about what "reviewed" means would be worse than either rule alone.
2. You asked for it that way: "it doesn't need to be on the latest head because I won't say LGTM until I'm confident that we're near the merge point anyway." A stamp that evaporates on the next push trains you to stop typing it.

Two self-test cases pin this as positive assertions rather than as deleted code, so silently re-adding freshness breaks the suite.

Rename: claude-review → review: bot + human LGTM

claude-review named the implementation of one half. It is wrong twice now: the check is not only about the Claude review, and the name tells you nothing about which half is red.

review: bot + human LGTM follows the repo's required-check convention (shell: sigpipe, deps: vulnerabilities, docs data: audit), and the two operands are the two halves — so a red entry in the checks list already says which question is open, and the word LGTM is visible on the PR page without opening anything. That visibility is the whole request.

Verification

• New self-test bin/test-check-human-lgtm.sh: 86 cases, over half negative controls. Every clause above has a case that fails without it: non-owner, login merely containing the owner's, LGTM in an issue comment, PENDING, lgtm?, LGTM ?, NOT LGTM, never LGTM, isn't LGTM, glued tokens, three fenced-block variants, a blockquote, an empty APPROVED, a forged marker. The harness also proves itself able to fail before running any case.
• Ten coupling assertions parse the gate out of .github/workflows/claude-code-review.yml and assert on its structure: it exists as a real (uncommented) step, reads the reviews endpoint, emits the marker the checker parses, carries a guard that is neither never-true nor changed from the intended one, swallows the checker's exit status nowhere, and ends with the checker invocation — and, at the level above, that both of the workflow's jobs are still guarded on the PR's author rather than the event's sender. A gate fed the wrong stream — or one whose step cannot run — would report success without having asked the question, this repo's most-repeated defect.
• These replaced four grep -F substring searches, which could not see a neutered step. Measured on a scratch copy: if: false on the step, || true on its pipeline, ; true, set +e, continue-on-error: true, and commenting the entire step out all left the suite green at 42/42, and one case was satisfied by two header comments alone. All eight sabotages now go red; the unsabotaged copy stays green. That was the failure class above occurring inside the guard written to prevent it.
• Thirty-seven sabotages in total, thirty-seven reds. Every case added in the review round below was run against the pre-fix code first — six of them go red there. The four that pin where a rule deliberately stops cannot, by construction, so each was proven against the plausible over-reaching fix instead. The eleven workflow-coupling sabotages were re-run against the edited workflow and all still bite.
• Re-replayed after every review round: the verdict on real reviews never moved. The checker as it now stands and the checker as it was before either round were both run over every review this repo has ever received — the 78 PRs that carry one. Both go green on exactly the same 38. Nothing regressed, nothing newly passed: five rounds and thirteen findings changed the verdict on zero real reviews — they closed synthetic holes without touching the habit the rule was measured against.
• Original replay against live API data for every PR in the repo that carries a review — 78 of them. 38 go green, and they are exactly the 38 with an owner LGTM: zero false positives and zero false negatives against an independently written matcher. ci(review): make the reviewer run on both routes, take the write token out of it, and ask the gate a simpler question #287 (reviewed repeatedly, never stamped) is among the reds. The instrument could have said yes, and did.
• bin/check-copyright-headers.sh, bin/check-issue-refs.sh, bin/check-docs-data.sh, bin/check-shell-sigpipe.sh, bin/check-action-versions.sh, and both gate self-tests: all pass locally.

What the automated review rounds found

Thirteen findings across five rounds, twelve taken and one declined with a measured counter-example, all upheld, all the same shape: a rule stated correctly in prose and implemented one step narrower than it reads.

1. The job guard read the event's sender, not the PR's author — a false GREEN on a required check. This is the serious one, and it predates this PR. github.event.sender is whoever triggered the event, which on synchronize, reopened and ready_for_review is frequently not the author: a bot pushing to a human's branch — and this repo has one that does — made the sender a Bot, which skipped the entire job, and a skipped job satisfies a required check. The documented exemption ("a bot-raised PR is not held to the review requirement") silently meant "a bot-touched PR", so any bot push turned the gate green with neither half asserted. That is this repo's most-repeated defect landing inside the gate written to prevent it. Now github.event.pull_request.user.type, which no event's sender can change — on the transitional claude-review job too, because that is the job the ruleset requires today, so a hole left there is a hole in practice for as long as the cutover takes. New case 26 pins both guards, for the same reason 25e/25f pin the step's.

2. The blockquote and fence exclusions did not survive a list marker. CommonMark lets a block start straight after one, so - > LGTM is a blockquote and - ```py opens a fence — but both tests only allowed leading whitespace, so a leading - carried a quoted LGTM straight past the exclusion written to catch it. (Continuation lines of a list item are plain indentation and always worked; it was the marker line itself that did not.) Markers are now stripped before either test, bounded at eight levels, and only for an opening fence: between two fences every line is literal code, where - is text. Cases 12g, 12h, 13b–13f.

Round one

3. The ? and negation clauses did not see across a soft line break, though Markdown does. A newline inside a paragraph renders as a space, so a body reading not\nLGTM or LGTM\n? is displayed to every human as "not LGTM" and "LGTM ?" — and hard-wrapped prose is the ordinary way to write it. Both stamped the PR. The scanner now runs one line behind the reader so each candidate can see its neighbours, and splices in exactly one line, only when that side of the token is otherwise empty. A blank line is a paragraph break and still separates them, which keeps this a rule you can state in a sentence rather than the unbounded sentiment analysis the checker refuses. Cases 9d/9e, 10f/10g.

Round two

4. A lazy blockquote continuation escaped the quote exclusion. CommonMark lets a paragraph inside a blockquote continue onto lines that drop the >, so > Bob said\nLGTM is one quoted paragraph with nothing of the owner's own outside it — and it stamped the PR. This is the likeliest of the three quote findings to be hit in practice, because quoting a line and answering it without a blank line is how people write. The quote now carries across the continuation, ending at a blank line, a fence, or a line starting a block a paragraph cannot lazily continue into. Both terminators have a positive control (13h, 13i), because "refuse everything after a >" passes the negative case just as well and would refuse most real reviews.

5. A four-space-indented closing fence closed the block. It must not: the fourth space makes the line code and the block stays open, so everything after it — including an LGTM — was read as prose. This one was a regression introduced by fix 2, which split opening from closing fences and carried ^[ \t]* across the closing side unexamined. Now ^ {0,3}, with 12j pinning that three spaces still closes: the over-tight fix (refuse all indentation) passes 12i perfectly well and is just as wrong.

Round three

6. Laziness was carried from every quoted line, not only from a paragraph — a false negative, and the first one these rounds produced. CommonMark will not lazily continue a heading, a fence, a list or an empty >, so > # context followed by a bare LGTM puts that LGTM outside the quote, where it is a real stamp. Fix 4 refused it. This direction of error is the one the whole check exists to avoid — a memory aid that rejects a stamp the owner really gave is a nuisance people route around, which is the argument that settled case-insensitivity in the first place. Cases 13k–13m.

7. .github/workflows/README.md listed an advisory check as required. It named review: bot + human LGTM among the contexts the master ruleset requires, while the sub-item directly below said claude-review is the one currently required — two statements that cannot both be true, in the one document whose job is to stop somebody getting the cutover wrong. Producing a context and being required are now stated as the different things they are.

8. Capping the opening fence at three spaces — DECLINED, and this thread is left open for @astubbs. The premise is correct: a four-space-indented backtick run is indented code, not a fence, so a real stamp after one is swallowed today. But the fix trades that rare false negative for a false positive, which is the wrong direction — and this was measured rather than argued. With the cap applied, a fence inside a nested list item (legitimately indented four spaces, because that is its content column) stops being recognised, and a fenced LGTM stamps the PR. Telling those apart needs every open list item's content column — a real block parser. That is precisely the boundary written down below, and this is the first finding to cross it. The escalation, which is why the thread is open: if this class should be closed properly, the answer is not more awk — it is to tighten the token rule so the stamp must be the bare word alone on a line (46 of the 50 real stamps already are), which makes every block-structure question moot. That changes what you have to type, so it is your call.

Round four — two regexes that were wider than their own prose

9. The n't contraction clause did not require the n. It read any word, any punctuation, a t — while the rule documented two lines above it has always said the contraction is the n-apostrophe-t one. So an ordinary technical token of that shape before the stamp was read as a negation and a real stamp refused: Traced it as far as src/t: LGTM went red. Another false negative, from a pattern nobody had compared against its own sentence. Cases 10h, 10i.

10. Starting a list and interrupting a paragraph are different questions, and one predicate was answering both. CommonMark lets an ordered list interrupt a paragraph only when it starts at 1, so > quoted\n2. LGTM leaves that LGTM inside the quote — and ending the quote on any numeral stamped it. A false positive on the one exclusion that exists because a review of this PR necessarily quotes the token. Split into starts_block() (broad, for "is the quoted content a paragraph?") and interrupts_paragraph() (narrow). Cases 13n, 13o, with 13i as the control.

11. docs/ci.md still called the advisory check required — round three fixed that contradiction in the workflow README and left the canonical CI document saying the opposite, which is worse than fixing neither. Both the prose and the lanes table now say what is true.

Also worth recording, because it cost real time: the awk program is a single-quoted shell string, so an apostrophe in one of its comments ends it. Writing n't in the comment explaining fix 9 broke the script outright. The self-test caught it in seconds — its harness refuses to run any case until a must-pass and a must-fail stream disagree, and here they agreed at exit 2. That guard exists because an assertion which has never failed proves nothing; this is the first time it has fired.

Round five

12. The cross-line splice crossed a hard break, which renders as the exact opposite of a soft one. Two trailing spaces (or a trailing backslash) render an actual line break, so the words either side are not adjacent — and joining them refused real stamps: not·· then LGTM went red, as did LGTM·· then ?. Fix 3 reached one line further than the rendering does. Cases 9f, 10j, 10k — with 9g as the boundary, because one trailing space is not a hard break and 9d must still refuse that; without it, "treat any trailing space as a break" passes the new cases and silently reopens the round-two hole. The splice now simply follows the rendered text: it crosses a soft break, stops at a blank line, stops at a hard break.

13. AGENTS.md still called the advisory context required — and this was the third round to report that same defect in a third file. Fixing them one per round was itself the mistake: the whole point of the correction is that the documents a maintainer consults mid-cutover must agree with each other, and patching one at a time guaranteed they did not. This round greps for the claim instead, which caught a fourth occurrence nobody had reported — the index table at the top of .github/workflows/README.md, whose conventions section had been fixed in round three while the table above it was missed.

And a stated boundary, which is not a fix

Three rounds have each found a real CommonMark shape the previous rule missed, and the supply is not exhausted — an indented code block ( LGTM) is not excluded either, nor are HTML blocks or setext headings. Rather than meet those one round at a time, bin/check-human-lgtm.sh now names them as known, deliberate non-exclusions and states why that is acceptable: a parser would close the list and this file cannot have one (it is a step of a required check, so a runner-image dependency that vanishes bricks every open PR — the same argument that keeps the self-test on awk rather than PyYAML); the error direction is toward calling text quoted, which refuses a stamp and says why; and the hole they are a corner of is already far wider by design, since the checker cannot tell a review giving an LGTM from one talking about one. Each fix is worth its cost while it is cheap and exact. If false positives ever matter more than the memory-aid framing admits, the answer is a tighter token rule — the bare word alone on a line, which 46 of the 50 real stamps already are — and that changes what @astubbs has to type, so it is his call.

Preserved deliberately

Read-only (contents: read, pull-requests: read — the reviews endpoint needs no new scope) · bot-raised PRs still exempt, and now only those · a fork PR still cannot satisfy the gate · no skip word, label or escape · the job still posts nothing.

A pull_request_review trigger is still deliberately NOT added, though the reason has changed and the old one is worth recording. It looks like the obvious way to clear the human half the moment the LGTM lands. It used to be a trap: on that event the sender is the reviewer, so a review submitted by a bot would have skipped the job on its sender.type != 'Bot' guard — and a skipped job reports a skipped check run, which GitHub counts as satisfying a required check.

That trap is closed, because the guard bug it depended on turned out to be a live defect in its own right and is fixed below. The trigger is nevertheless left unwired here: it changes when a required check runs, which is its own decision rather than a side effect of this one. Until it is made, the LGTM needs the same re-run the automated half already documents — or just leave the LGTM before asking for the automated review, and the reviewer's refresh-gate job re-runs the gate with both halves already true.

---

⚠️ Ruleset cutover — for @astubbs to run at merge time

I have not touched the ruleset. claude-review is currently required in ruleset 15055005, and a required context that nothing reports blocks every open PR with no way to clear it. So this PR does not remove the old name: it adds a transitional second job that keeps reporting claude-review under the old contract (automated review only), so both names report during the swap and no window exists where a required context is unproduced.

The transitional job deliberately does not use needs: on the real job. A job that skips when its dependency fails reports skipped, which GitHub counts as satisfying a required check — the mirror would have gone green exactly when the gate went red. Hence duplicated steps, with a stated deletion condition in its header.

Step 1 — merge this PR

Nothing changes for anyone. claude-review is still required and still reports, under the same contract it has today. The new context review: bot + human LGTM reports alongside it as an advisory canary asserting both halves.

Step 2 — watch the canary (optional, recommended)

Open or push a PR and look at the new check. It should be red with NO HUMAN LGTM ON THIS PR ...; submit a review saying lgtm, re-run the gate run, and it should go green.

gh pr checks <n> -R astubbs/parallel-consumer | grep -i review

Step 3 — swap the required context (one atomic PUT)

Both contexts are reporting at this point, so there is no gap. Snapshot first — this file is the rollback.

cd "$(mktemp -d)"

# 1. Snapshot the whole ruleset. KEEP THIS FILE until step 5 is done.
gh api repos/astubbs/parallel-consumer/rulesets/15055005 > rs.before.json

# 2. Build the new body: strip the read-only fields the PUT does not accept,
#    and rewrite exactly one context string.
jq '{name, target, enforcement, bypass_actors, conditions, rules}
    | (.rules[] | select(.type == "required_status_checks")
       | .parameters.required_status_checks[]
       | select(.context == "claude-review") | .context) = "review: bot + human LGTM"' \
   rs.before.json > rs.after.json

# 3. LOOK AT THE DIFF BEFORE SENDING IT. The only semantic change must be the one
#    context; everything else dropped is read-only metadata (_links, id, node_id,
#    created_at, updated_at, source, source_type, current_user_can_bypass).
diff <(jq -S . rs.before.json) <(jq -S . rs.after.json)

# 4. Send it.
gh api -X PUT repos/astubbs/parallel-consumer/rulesets/15055005 --input rs.after.json

I dry-ran steps 1–3 locally: the transform touches exactly one string and preserves its integration_id: 15368. I did not run step 4.

Step 4 — verify the swap

gh api repos/astubbs/parallel-consumer/rules/branches/master \
  --jq '.[] | select(.type=="required_status_checks")
        | .parameters.required_status_checks[].context' | sort

Expect review: bot + human LGTM present and claude-review absent.

Then unblock the PRs that were already open. For pull_request events the workflow file comes from the merge ref, so an open PR only starts producing the new context after a fresh event. Re-running an existing run replays the old workflow file and will not help. For each open PR, push a commit or close-and-reopen it (reopened is in the gate's trigger list):

gh pr list -R astubbs/parallel-consumer --json number -q '.[].number'
gh pr close <n> -R astubbs/parallel-consumer && gh pr reopen <n> -R astubbs/parallel-consumer

Doing the swap when few PRs are open makes this cheap.

Step 5 — delete the transitional job (a follow-up PR, after step 4)

Remove the claude-review job from .github/workflows/claude-code-review.yml, and the transitional paragraphs in its header and in docs/ci.md. Doing this before step 3 is what bricks the repo.

Rollback, at any point before step 5

gh api -X PUT repos/astubbs/parallel-consumer/rulesets/15055005 --input rs.before.json

rs.before.json is the exact prior state, so this is a true revert. After step 5 it is not — the old job no longer exists to report claude-review, so roll the code back first.

---

Checklist

• Docs updated — the canonical gate contract in docs/ci.md now states both halves and the full matching rule; the red-gate section, the workflow table, AGENTS.md and .github/workflows/README.md follow the rename
• N/A - CI/repo tooling, not a user-facing library feature — no docs/features/ entry
• Tests added/updated — new bin/test-check-human-lgtm.sh (86 cases, over half negative controls, including ten structural workflow-coupling assertions), run by the gate before it trusts the checker
• Title & body reflect the final content of this PR

[github-actions]

Dependency Review

✅ No vulnerabilities or license issues or OpenSSF Scorecard issues found.

Scanned Files

None

[github-actions]

✅ Duplicate Code Report

Two engines run in parallel for cross-validation. Each has its own thresholds tuned to its baseline - the real safety net is the per-engine "max increase vs base" check.

✅ PMD CPD

	PR	Base	Change
Clones	24	24	➖ 0
Duplicated lines	721	721	➖ 0
Duplication	1.94%	1.94%	➖ 0

Rule	Limit	Status
Max duplication	5%	✅ Pass (1.94%)
Max increase vs base	+0.1%	✅ Pass (+0.00%)

No new clones introduced by this PR.

✅ jscpd (language-agnostic)

	PR	Base	Change
Clones	66	66	➖ 0
Duplicated lines	933	933	➖ 0
Duplication	2.54%	2.54%	➖ 0

Rule	Limit	Status
Max duplication	5%	✅ Pass (2.54%)
Max increase vs base	+0.1%	✅ Pass (+0.00%)

No new clones introduced by this PR.

_{Powered by astubbs/duplicate-code-cross-check}

[github-actions]

📌 Duplicate code detection tool report

The tool analyzed your source code and found the following degree of similarity between the files:

✅ No new or increased file similarities introduced by this PR.

Full similarity report

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ExceptionInUserFunctionException.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ExceptionInUserFunctionException.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelConsumerException.java	53.51 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java	38.69
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PCRetriableException.java	35.81
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/EncodingNotSupportedException.java	35.12
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV1EncodingNotSupported.java	33.88
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/BitSetEncodingNotSupportedException.java	33.73
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV2EncodingNotSupported.java	33.04
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/OffsetDecodingError.java	32.81

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelEoSStreamProcessor.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelEoSStreamProcessor.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelStreamProcessor.java	61.97 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessor.java	55.67 ⚠️
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelEoSStreamProcessor.java	40.72
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelStreamProcessor.java	38.25
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PollContextInternal.java	33.44
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelStreamProcessor.java	31.88
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/PCModule.java	30.42

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelStreamProcessor.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelStreamProcessor.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelEoSStreamProcessor.java	61.97 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessor.java	51.77 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelStreamProcessor.java	37.84
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelEoSStreamProcessor.java	33.04
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PollContextInternal.java	32.46
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelStreamProcessor.java	30.91
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/PCModule.java	30.82

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PCRetriableException.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PCRetriableException.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ExceptionInUserFunctionException.java	35.81
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java	32.72

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelConsumerException.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelConsumerException.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ExceptionInUserFunctionException.java	53.51 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java	51.67 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/EncodingNotSupportedException.java	42.94
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/BitSetEncodingNotSupportedException.java	33.24
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/OffsetDecodingError.java	31.95
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalRuntimeException.java	30.75

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelConsumerOptions.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelConsumerOptions.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/ProducerManager.java	32.86

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessor.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessor.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelEoSStreamProcessor.java	55.67 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelStreamProcessor.java	51.77 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelStreamProcessor.java	46.39
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PollContextInternal.java	34.52
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/AbstractParallelEoSStreamProcessor.java	33.11
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/TestParallelEoSStreamProcessor.java	31.59
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/PCModule.java	30.13
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelEoSStreamProcessor.java	30.06

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelStreamProcessor.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelStreamProcessor.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessor.java	46.39
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelEoSStreamProcessor.java	38.25
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelStreamProcessor.java	37.84
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelStreamProcessor.java	33.69

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PollContext.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PollContext.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/RecordContextInternal.java	39.94
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PollContextInternal.java	31.07

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PollContextInternal.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PollContextInternal.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessor.java	34.52
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelEoSStreamProcessor.java	33.44
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/RecordContextInternal.java	32.71
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelStreamProcessor.java	32.46
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PollContext.java	31.07

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/RecordContextInternal.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/RecordContextInternal.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PollContext.java	39.94
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PollContextInternal.java	32.71

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/AbstractParallelEoSStreamProcessor.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/AbstractParallelEoSStreamProcessor.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessor.java	33.11
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/BrokerPollSystem.java	32.49

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/BrokerPollSystem.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/BrokerPollSystem.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/AbstractParallelEoSStreamProcessor.java	32.49

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/ExternalEngine.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/ExternalEngine.java

File	Similarity (%)
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/VertxParallelEoSStreamProcessor.java	39.51

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/EncodingNotSupportedException.java	59.33 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelConsumerException.java	51.67 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/OffsetDecodingError.java	50.43 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/NoEncodingPossibleException.java	48.06
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalRuntimeException.java	39.89
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ExceptionInUserFunctionException.java	38.69
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/BitSetEncodingNotSupportedException.java	35.64
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/PCRetriableException.java	32.72
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV1EncodingNotSupported.java	32.57
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV2EncodingNotSupported.java	31.76

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalRuntimeException.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalRuntimeException.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java	39.89
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/EncodingNotSupportedException.java	31.25
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelConsumerException.java	30.75

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/PCModule.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/PCModule.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/PCModuleTestEnv.java	32.08
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelStreamProcessor.java	30.82
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelEoSStreamProcessor.java	30.42
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessor.java	30.13

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/ProducerManager.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/ProducerManager.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelConsumerOptions.java	32.86
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/ProducerManagerTest.java	30.14

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/utils/Java8StreamUtils.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/utils/Java8StreamUtils.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/utils/JavaUtils.java	34.67
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/CollectionUtils.java	32.47

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/utils/JavaUtils.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/utils/JavaUtils.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/CollectionUtils.java	38.96
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/utils/Java8StreamUtils.java	34.67

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/BitSetEncodingNotSupportedException.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/BitSetEncodingNotSupportedException.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/EncodingNotSupportedException.java	50.35 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV1EncodingNotSupported.java	36.78
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV2EncodingNotSupported.java	35.85
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java	35.64
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ExceptionInUserFunctionException.java	33.73
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelConsumerException.java	33.24
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/OffsetDecodingError.java	31.69

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/EncodingNotSupportedException.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/EncodingNotSupportedException.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java	59.33 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/BitSetEncodingNotSupportedException.java	50.35 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/OffsetDecodingError.java	47.72
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV1EncodingNotSupported.java	46.85
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/NoEncodingPossibleException.java	45.7
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV2EncodingNotSupported.java	45.68
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelConsumerException.java	42.94
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ExceptionInUserFunctionException.java	35.12
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalRuntimeException.java	31.25

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/NoEncodingPossibleException.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/NoEncodingPossibleException.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java	48.06
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/EncodingNotSupportedException.java	45.7
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/OffsetDecodingError.java	45.29
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV1EncodingNotSupported.java	36.73
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV2EncodingNotSupported.java	35.81

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/OffsetDecodingError.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/OffsetDecodingError.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java	50.43 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/EncodingNotSupportedException.java	47.72
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/NoEncodingPossibleException.java	45.29
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ExceptionInUserFunctionException.java	32.81
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelConsumerException.java	31.95
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/BitSetEncodingNotSupportedException.java	31.69
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV1EncodingNotSupported.java	30.64

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV1EncodingNotSupported.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV1EncodingNotSupported.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV2EncodingNotSupported.java	63.08 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/EncodingNotSupportedException.java	46.85
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/BitSetEncodingNotSupportedException.java	36.78
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/NoEncodingPossibleException.java	36.73
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ExceptionInUserFunctionException.java	33.88
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java	32.57
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/OffsetDecodingError.java	30.64

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV2EncodingNotSupported.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV2EncodingNotSupported.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/RunLengthV1EncodingNotSupported.java	63.08 ⚠️
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/EncodingNotSupportedException.java	45.68
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/BitSetEncodingNotSupportedException.java	35.85
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/offsets/NoEncodingPossibleException.java	35.81
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ExceptionInUserFunctionException.java	33.04
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/InternalException.java	31.76

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/PartitionState.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/PartitionState.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/PartitionStateManager.java	32.64

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/PartitionStateManager.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/PartitionStateManager.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/WorkManager.java	38.53
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/PartitionState.java	32.64

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/ProcessingShard.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/ProcessingShard.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/ShardManager.java	35.84

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/ShardManager.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/ShardManager.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/ProcessingShard.java	35.84

parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/WorkManager.java

📄 parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/WorkManager.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/state/PartitionStateManager.java	38.53

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/KafkaSanityTests.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/KafkaSanityTests.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/LoopingResumingIteratorTest.java	34.68

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/MultiInstanceHighVolumeTest.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/MultiInstanceHighVolumeTest.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/VeryLargeMessageVolumeTest.java	57.01 ⚠️
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/TransactionAndCommitModeTest.java	43.51
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/MultiInstanceRebalanceTest.java	35.49

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/MultiInstanceRebalanceTest.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/MultiInstanceRebalanceTest.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/VeryLargeMessageVolumeTest.java	39.54
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/TransactionAndCommitModeTest.java	38.98
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/MultiInstanceHighVolumeTest.java	35.49

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/RebalanceEoSDeadlockTest.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/RebalanceEoSDeadlockTest.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/RebalanceTest.java	36.17

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/RebalanceTest.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/RebalanceTest.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/RebalanceEoSDeadlockTest.java	36.17

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/TransactionAndCommitModeTest.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/TransactionAndCommitModeTest.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/VeryLargeMessageVolumeTest.java	53.93 ⚠️
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/MultiInstanceHighVolumeTest.java	43.51
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/MultiInstanceRebalanceTest.java	38.98
parallel-consumer-vertx/src/test-integration/java/bz/stub/parallelconsumer/vertx/integrationTests/VertxConcurrencyIT.java	31.36

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/TransactionTimeoutsTest.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/TransactionTimeoutsTest.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/ProducerManagerTest.java	31.05

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/VeryLargeMessageVolumeTest.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/VeryLargeMessageVolumeTest.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/MultiInstanceHighVolumeTest.java	57.01 ⚠️
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/TransactionAndCommitModeTest.java	53.93 ⚠️
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/MultiInstanceRebalanceTest.java	39.54
parallel-consumer-vertx/src/test-integration/java/bz/stub/parallelconsumer/vertx/integrationTests/VertxConcurrencyIT.java	35.26

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/AbstractRevokeUnderWorkScenario.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/AbstractRevokeUnderWorkScenario.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosChurnStormIT.java	49.09
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosRevokeUnderWorkIT.java	35.14

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosChurnStormIT.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosChurnStormIT.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/AbstractRevokeUnderWorkScenario.java	49.09
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosScenarioBase.java	37.92

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosConductorRestartRefusalIT.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosConductorRestartRefusalIT.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/utils/ManagedPCInstanceLifecycleIT.java	30.4

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosRevokeUnderWorkCooperativeIT.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosRevokeUnderWorkCooperativeIT.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosRevokeUnderWorkIT.java	47.74

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosRevokeUnderWorkIT.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosRevokeUnderWorkIT.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosRevokeUnderWorkCooperativeIT.java	47.74
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/AbstractRevokeUnderWorkScenario.java	35.14

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosScenarioBase.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosScenarioBase.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosChurnStormIT.java	37.92

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/utils/ManagedPCInstance.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/utils/ManagedPCInstance.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/utils/ManagedPCInstanceLifecycleIT.java	33.96

parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/utils/ManagedPCInstanceLifecycleIT.java

📄 parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/utils/ManagedPCInstanceLifecycleIT.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/utils/ManagedPCInstance.java	33.96
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/chaostests/ChaosConductorRestartRefusalIT.java	30.4

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/AbstractParallelEoSStreamProcessorTestBase.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/AbstractParallelEoSStreamProcessorTestBase.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/KafkaTestUtils.java	32.95

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/BatchTestBase.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/BatchTestBase.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/CoreBatchTest.java	30.28

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/CheckQuarantineOwnersScriptTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/CheckQuarantineOwnersScriptTest.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/QuarantineLaneReportScriptTest.java	49.61
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/QuarantineRegistryScriptTest.java	47.62

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/CoreBatchTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/CoreBatchTest.java

File	Similarity (%)
parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorBatchTest.java	51.73 ⚠️
parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyBatchTest.java	50.43 ⚠️
parallel-consumer-vertx/src/test/java/bz/stub/parallelconsumer/vertx/VertxBatchTest.java	44.54
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/BatchTestBase.java	30.28

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/MockConsumerCommitTimeoutTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/MockConsumerCommitTimeoutTest.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/MockConsumerSaslAuthenticationTest.java	43.76

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/MockConsumerSaslAuthenticationTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/MockConsumerSaslAuthenticationTest.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/MockConsumerCommitTimeoutTest.java	43.76

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/ParallelEoSSStreamProcessorRebalancedTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/ParallelEoSSStreamProcessorRebalancedTest.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessorTest.java	33.25

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessorTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessorTest.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/ParallelEoSSStreamProcessorRebalancedTest.java	33.25

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/QuarantineLaneReportScriptTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/QuarantineLaneReportScriptTest.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/CheckQuarantineOwnersScriptTest.java	49.61
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/QuarantineRegistryScriptTest.java	33.02

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/QuarantineRegistryScriptTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/QuarantineRegistryScriptTest.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/CheckQuarantineOwnersScriptTest.java	47.62
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/QuarantineLaneReportScriptTest.java	33.02

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/TestConventionsArchTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/TestConventionsArchTest.java

File	Similarity (%)
parallel-consumer-vertx/src/test/java/bz/stub/parallelconsumer/vertx/TestConventionsArchTest.java	90.0 ⚠️
parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/TestConventionsArchTest.java	89.32 ⚠️
parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/TestConventionsArchTest.java	89.32 ⚠️

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/PCModuleTestEnv.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/PCModuleTestEnv.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/PCModule.java	32.08

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/ProducerManagerTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/ProducerManagerTest.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/TransactionTimeoutsTest.java	31.05
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/ProducerManager.java	30.14

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/TestParallelEoSStreamProcessor.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/TestParallelEoSStreamProcessor.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessor.java	31.59

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/BlockedThreadAsserter.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/BlockedThreadAsserter.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/BlockedThreadAsserterTest.java	34.5

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/BlockedThreadAsserterTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/BlockedThreadAsserterTest.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/BlockedThreadAsserter.java	34.5

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/CollectionUtils.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/CollectionUtils.java

File	Similarity (%)
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/utils/JavaUtils.java	38.96
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/utils/Java8StreamUtils.java	32.47

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/KafkaTestUtils.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/KafkaTestUtils.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/AbstractParallelEoSStreamProcessorTestBase.java	32.95

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/LoopingResumingIteratorTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/internal/utils/LoopingResumingIteratorTest.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/KafkaSanityTests.java	34.68

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/offsets/OffsetEncodingBackPressureTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/offsets/OffsetEncodingBackPressureTest.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/offsets/OffsetEncodingBackPressureUnitTest.java	38.88

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/offsets/OffsetEncodingBackPressureUnitTest.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/offsets/OffsetEncodingBackPressureUnitTest.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/offsets/OffsetEncodingBackPressureTest.java	38.88

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/truth/CommitHistorySubject.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/truth/CommitHistorySubject.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/truth/LongPollingMockConsumerSubject.java	36.14

parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/truth/LongPollingMockConsumerSubject.java

📄 parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/truth/LongPollingMockConsumerSubject.java

File	Similarity (%)
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/truth/CommitHistorySubject.java	36.14

parallel-consumer-mutiny/src/main/java/bz/stub/parallelconsumer/mutiny/MutinyProcessor.java

📄 parallel-consumer-mutiny/src/main/java/bz/stub/parallelconsumer/mutiny/MutinyProcessor.java

File	Similarity (%)
parallel-consumer-reactor/src/main/java/bz/stub/parallelconsumer/reactor/ReactorProcessor.java	51.65 ⚠️

parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyBatchTest.java

📄 parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyBatchTest.java

File	Similarity (%)
parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorBatchTest.java	78.79 ⚠️
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/CoreBatchTest.java	50.43 ⚠️
parallel-consumer-vertx/src/test/java/bz/stub/parallelconsumer/vertx/VertxBatchTest.java	48.59

parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyPCTest.java

📄 parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyPCTest.java

File	Similarity (%)
parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorPCTest.java	71.0 ⚠️

parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyTest.java

📄 parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyTest.java

File	Similarity (%)
parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorTest.java	33.05

parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyUnitTestBase.java

📄 parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyUnitTestBase.java

File	Similarity (%)
parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorUnitTestBase.java	31.86

parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/TestConventionsArchTest.java

📄 parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/TestConventionsArchTest.java

File	Similarity (%)
parallel-consumer-vertx/src/test/java/bz/stub/parallelconsumer/vertx/TestConventionsArchTest.java	90.8 ⚠️
parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/TestConventionsArchTest.java	90.11 ⚠️
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/TestConventionsArchTest.java	89.32 ⚠️

parallel-consumer-reactor/src/main/java/bz/stub/parallelconsumer/reactor/ReactorProcessor.java

📄 parallel-consumer-reactor/src/main/java/bz/stub/parallelconsumer/reactor/ReactorProcessor.java

File	Similarity (%)
parallel-consumer-mutiny/src/main/java/bz/stub/parallelconsumer/mutiny/MutinyProcessor.java	51.65 ⚠️

parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorBatchTest.java

📄 parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorBatchTest.java

File	Similarity (%)
parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyBatchTest.java	78.79 ⚠️
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/CoreBatchTest.java	51.73 ⚠️
parallel-consumer-vertx/src/test/java/bz/stub/parallelconsumer/vertx/VertxBatchTest.java	49.83

parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorPCTest.java

📄 parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorPCTest.java

File	Similarity (%)
parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyPCTest.java	71.0 ⚠️

parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorTest.java

📄 parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorTest.java

File	Similarity (%)
parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyTest.java	33.05

parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorUnitTestBase.java

📄 parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorUnitTestBase.java

File	Similarity (%)
parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyUnitTestBase.java	31.86

parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/TestConventionsArchTest.java

📄 parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/TestConventionsArchTest.java

File	Similarity (%)
parallel-consumer-vertx/src/test/java/bz/stub/parallelconsumer/vertx/TestConventionsArchTest.java	90.8 ⚠️
parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/TestConventionsArchTest.java	90.11 ⚠️
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/TestConventionsArchTest.java	89.32 ⚠️

parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelEoSStreamProcessor.java

📄 parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelEoSStreamProcessor.java

File	Similarity (%)
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/VertxParallelEoSStreamProcessor.java	40.93
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelEoSStreamProcessor.java	40.72
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelStreamProcessor.java	40.18
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/VertxParallelStreamProcessor.java	35.89
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelStreamProcessor.java	33.04
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelEoSStreamProcessor.java	30.06

parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelStreamProcessor.java

📄 parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelStreamProcessor.java

File	Similarity (%)
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelEoSStreamProcessor.java	40.18
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/VertxParallelStreamProcessor.java	40.17
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/ParallelStreamProcessor.java	33.69
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelEoSStreamProcessor.java	31.88
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/JStreamParallelStreamProcessor.java	30.91

parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/VertxParallelEoSStreamProcessor.java

📄 parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/VertxParallelEoSStreamProcessor.java

File	Similarity (%)
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/VertxParallelStreamProcessor.java	42.84
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelEoSStreamProcessor.java	40.93
parallel-consumer-core/src/main/java/bz/stub/parallelconsumer/internal/ExternalEngine.java	39.51

parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/VertxParallelStreamProcessor.java

📄 parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/VertxParallelStreamProcessor.java

File	Similarity (%)
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/VertxParallelEoSStreamProcessor.java	42.84
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelStreamProcessor.java	40.17
parallel-consumer-vertx/src/main/java/bz/stub/parallelconsumer/vertx/JStreamVertxParallelEoSStreamProcessor.java	35.89

parallel-consumer-vertx/src/test-integration/java/bz/stub/parallelconsumer/vertx/integrationTests/VertxConcurrencyIT.java

📄 parallel-consumer-vertx/src/test-integration/java/bz/stub/parallelconsumer/vertx/integrationTests/VertxConcurrencyIT.java

File	Similarity (%)
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/VeryLargeMessageVolumeTest.java	35.26
parallel-consumer-core/src/test-integration/java/bz/stub/parallelconsumer/integrationTests/TransactionAndCommitModeTest.java	31.36

parallel-consumer-vertx/src/test/java/bz/stub/parallelconsumer/vertx/TestConventionsArchTest.java

📄 parallel-consumer-vertx/src/test/java/bz/stub/parallelconsumer/vertx/TestConventionsArchTest.java

File	Similarity (%)
parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/TestConventionsArchTest.java	90.8 ⚠️
parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/TestConventionsArchTest.java	90.8 ⚠️
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/TestConventionsArchTest.java	90.0 ⚠️

parallel-consumer-vertx/src/test/java/bz/stub/parallelconsumer/vertx/VertxBatchTest.java

📄 parallel-consumer-vertx/src/test/java/bz/stub/parallelconsumer/vertx/VertxBatchTest.java

File	Similarity (%)
parallel-consumer-reactor/src/test/java/bz/stub/parallelconsumer/reactor/ReactorBatchTest.java	49.83
parallel-consumer-mutiny/src/test/java/bz/stub/parallelconsumer/mutiny/MutinyBatchTest.java	48.59
parallel-consumer-core/src/test/java/bz/stub/parallelconsumer/CoreBatchTest.java	44.54

[github-actions]

✅ SpotBugs Report

No bugs found (new bugs only — baseline from base branch excluded).

[github-actions]

🧪🔒 Quarantine Lane Report

Quarantined test	Outcome	Owner	Meaning
ProducerManagerTest.producedRecordsCantBeInTransactionWithoutItsOffsetDirect	🟡🎲 passed (flapper)	#262	proves nothing - passes most runs by nature
OffsetEncodingBackPressureTest.backPressureShouldPreventTooManyMessagesBeingQueuedForProcessing	🟡🎲 passed (flapper)	⚠️ unowned	proves nothing - passes most runs by nature

_{🔴 expected while the owner PR is open · 🟡🎲 flapper, pass proves nothing · 🚨 a deterministic quarantined test passing means its fix landed: delete its @Quarantined annotation + docs/quarantined-tests.md entry (a merge-blocking review thread has been opened). Lane: non-gating; rules: see the Quarantine Audit check.}

[chatgpt-codex-connector]

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: ac8ed48b3f

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

• Open a pull request for review
• Mark a draft as ready
• Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

[astubbs]

@claude review this

Context for the review: the branch has moved twice since the last round.

1. Merged master in (d568c7f7f) so this is tested against what it will land on — clean, no conflicts, despite both sides touching AGENTS.md (different sections: master added the docs/inflight/AGENTS.md routing row at the top, this branch edited the review-gate paragraph near the bottom).
2. Acted on the three automated findings (85d38097e), all upheld — details in the three resolved threads and in the PR description under "What the automated review round found".

The one worth a fresh pair of eyes is finding 1, because the fix reaches beyond the reported line: the job guard read github.event.sender.type, which is the event's trigger, not the PR's author — so a bot pushing to a human's branch skipped the whole job, and a skipped job satisfies a required check. Both jobs now read github.event.pull_request.user.type, including the transitional claude-review one, and a new self-test case 26 pins both guards.

Please pay particular attention to:

• The awk rewrite in bin/check-human-lgtm.sh. The scanner now runs one line behind the reader so the ? and negation clauses can see across a soft line break, and list markers are stripped before the blockquote/fence tests. Both are changes to the matching rule of a required check, so a false positive here is a gate that stamps a PR nobody stamped. The asymmetry I would most like checked: a fence may open behind a list marker but may only close in the plain form (case 12h).
• Whether bin/test-check-human-lgtm.sh still fails for the right reasons. Eleven sabotages were run and all eleven go red, listed in the commit message — but two earlier candidates did not bite and had to be reworked, so the suite has already proven it can be fooled.
• Anything I got wrong in the three thread replies, particularly the argument for extending the fence fix beyond what was reported.

Not in scope: the ruleset itself (untouched, and the cutover checklist in the description is for @astubbs to run at merge time), and the transitional claude-review job, which must not be deleted before the ruleset swap.

[claude]

Claude finished @astubbs's task in 7m 24s —— View job

---

Review

• Gather context (PR description, diff, prior review threads)
• Review the workflow guard fix (github.event.pull_request.user.type on both jobs)
• Review the bin/check-human-lgtm.sh awk rewrite (soft-line-break handling, list-marker stripping, fence asymmetry)
• Review bin/test-check-human-lgtm.sh self-test coverage for the new cases
• Check the three thread replies for accuracy
• Post final review

A caveat up front: this sandbox's Bash tool refused every attempt to actually execute a script (bin/test-check-human-lgtm.sh, or a scratch repro against bin/check-human-lgtm.sh — even a bare python3 -c ...), so I could not run the self-test suite or confirm my repro below by executing it. Everything below is a manual/static trace of the awk state machine and the workflow YAML, not a live run. If you want it actually executed, --allowedTools needs to permit running bin/ scripts in this session.

The job-guard fix (finding 1) — looks correct

github.event.pull_request.user.type != 'Bot' now guards both review-gate (.github/workflows/claude-code-review.yml:117) and the transitional claude-review (:267), matching what bin/test-check-human-lgtm.sh case 26 (bin/test-check-human-lgtm.sh:672-696) asserts via its own YAML-parsing job_if(). I checked that parser against the real indentation (grep -n for ^ review-gate: / ^ if:) and it lines up with what the awk state machine expects, so case 26 isn't a test that would pass against the wrong thing.

The Assert the repository owner has left an LGTM step's guard, !cancelled() && steps.automated-review.conclusion != 'skipped', does what the comment above it claims: because the expression uses a status-check function (cancelled()), Actions doesn't implicitly AND it with success(), so the step still runs when the automated-review step fails (conclusion failure, not skipped) but is correctly skipped when a prior step never ran (fork refusal, failed self-test) and automated-review itself gets marked skipped. Traced through both branches by hand and both land where the header says they should.

The awk rewrite — the two claimed fixes hold up; one gap does not

I hand-traced the soft-line-break splice (bin/check-human-lgtm.sh:264-296) and the marker-stripping asymmetry (:246-262, :298-303) against several inputs, including the boundary the PR description calls out specifically (case 12h: a marker-prefixed fence line inside an already-open fence must not close it). Both are correct as implemented — fence_line() only consults strip_markers() when !fenced, so a - inside an open block is read as literal code, exactly as intended. I also traced the "blank line still separates" property (case 9e/10g shape) by hand: because blank lines flow through the same pending/flush mechanism as any other line, prev_line at the point a token is scanned is the immediately preceding line's content — if that's a blank line, nothing gets spliced across it, so a real paragraph break still defeats the negation/? lookback. That's subtle and it's implemented correctly.

What I don't think is covered: blockquote lazy continuation. The blockquote exclusion (bin/check-human-lgtm.sh:399-403):

open && (fenced || strip_markers($0) ~ /^>/) {
    break_para()
    if ($0 ~ /[Ll][Gg][Tt][Mm]/) note_near("quoted")
    next
}

only recognizes "inside a blockquote" by a literal > on that line. Unlike fences, there's no persistent state (no in_quote variable analogous to fenced) — so a line that continues a blockquote's paragraph without repeating the > still gets scanned as ordinary text. CommonMark blockquotes support exactly this ("lazy continuation": > foo followed by a bare bar on the next line renders as one blockquote, <p>foo\nbar</p>, no blank line needed). Traced through the state machine by hand for the review body:

> Someone said this
LGTM

• Line 1 (> Someone said this): matches the blockquote branch, break_para() resets prev_line="", no LGTM on this line so nothing noted, next.
• Line 2 (LGTM): does not match the blockquote branch (no > prefix, fenced is false) or the fence branch, so it falls to the generic open { flush($0); pending=$0; ... } path — an ordinary candidate line.
• At END, scan("LGTM", prev_line="", nextl="") finds the token with clean word boundaries, no ?, negated("") false → seg_ok = 1 → the review passes.

But this body renders on GitHub as a single blockquote — "Someone said this LGTM" — which is exactly the "review quoting somebody else's LGTM ... does not stamp by accident" property this rule set out to guarantee (stated in the header at bin/check-human-lgtm.sh:102-105, and the reason list-marker nesting and code-fence nesting were both closed in this same round). This is the same shape of bug as the two already-fixed findings — an exclusion that doesn't survive a CommonMark structural form — just a third form (lazy blockquote continuation) that isn't addressed. A minimal fix would track a persistent quote state the same way fenced is tracked: set it when a marker-stripped line starts with >, keep it true across continuation lines, and clear it on a blank line (which is what ends a blockquote's lazy continuation per CommonMark) — then route those lines through the same "quoted" exclusion fenced lines already get. Given bin/test-check-human-lgtm.sh has no case for this shape (only 13/13b-d, which all put the LGTM on the > line itself or the blank-line-separated non-continuation form), I'd add one alongside 12g/13b.

Since I couldn't execute anything, I'd treat this as plausible, not confirmed by a live run — please sanity-check the trace against the real script before treating it as certain, though I went through the state transitions fairly carefully.

Fix this →

On the self-test suite failing "for the right reasons"

I couldn't execute bin/test-check-human-lgtm.sh, so I can't independently confirm the eleven-sabotage claim by running it. What I could check statically: the workflow-coupling assertions (25b–25h, 26) parse the real step/job text out of the actual .github/workflows/claude-code-review.yml via gate_step()/job_if() rather than a hardcoded copy, so they can't drift from what's actually deployed — and I confirmed by inspection that the expected strings they assert against (EXPECTED_IF, EXPECTED_JOB_IF, EXPECTED_LAST) match the file as it stands today. That's a meaningfully stronger property than the "four grep -F substring searches" this replaced, and matches the PR description's claim about it.

On the three thread replies

All three read accurate against the code as I traced it — the sender vs pull_request.user mechanism, the CommonMark reasoning for list-marker-before-blockquote/fence (including why the fence-close case is deliberately asymmetric), and the soft-line-break splice bound (one line, only when the token's side is otherwise empty, blank line still separates). I didn't find anything to correct in them. The blockquote-continuation gap above is a genuinely new observation, not a contradiction of anything claimed in those replies — the replies don't claim blockquote handling is exhaustive, only that the two reported findings are fixed.

Not reviewed (per your scope note)

The ruleset cutover steps and the transitional claude-review job's lifecycle — description already covers these and they're explicitly out of scope for this pass.

[chatgpt-codex-connector]

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: 85d38097e7

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

• Open a pull request for review
• Mark a draft as ready
• Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

[astubbs]

Thanks — replying to the one substantive finding, and flagging a limitation of this review round that @astubbs should know about.

The lazy-blockquote-continuation gap: correct, and already closed

Your trace is right. I can confirm it by execution, which you could not: against the checker as it stood at 85d38097e (the head you reviewed), the body

> Bob asked whether this was fine and I said
LGTM

exits 0 — a stamp. It renders as one quoted paragraph. So the state transitions you walked through by hand were accurate, and "plausible, not confirmed by a live run" understates it.

It is fixed in 15b65926a, which landed a few minutes before your review posted — Codex found the same shape independently in a parallel round, so the two of you converged on it from different directions. Implementation is close to what you proposed, with two differences worth naming since you specified the termination rule:

• You suggested clearing the state on a blank line. That is necessary but not sufficient: a fence and a list item also interrupt a paragraph, so > quoted followed by - LGTM is a list item outside the quote and must still stamp. The implementation clears on a blank line, on a fence, and on a line starting a block a paragraph cannot lazily continue into (list marker, ATX heading).
• Because of that, the fix carries two positive controls (13h, 13i) alongside the negative case (13g). This matters more than it looks: sabotaging the rule to the blank-line-only version leaves 13g green and turns 13i red. A negative case alone would have accepted the narrower fix.

Sabotage-proved: 13g goes red against 85d38097e; 13h and 13i are boundary pins so they cannot, and were proven against the two over-reaching variants (laziness with no terminators, laziness ignoring block starts).

The class, rather than the instance

That was the third CommonMark shape found in three rounds — list nesting, the closing-fence indent, and now this. The supply is not exhausted: an indented code block ( LGTM after a blank line) is not excluded either, nor are HTML blocks or setext headings. So bin/check-human-lgtm.sh now names them as known, deliberate non-exclusions rather than leaving them to be found one per round, with the argument for why that is acceptable — the error direction, the impossibility of carrying a parser inside a required check's own self-test, and the fact that this checker already cannot tell a review giving an LGTM from one talking about one. Details in the resolved thread on that line and in the PR description.

The verification you could not run, run

• 73 self-test cases, all green; 24 sabotages across both rounds, 24 reds.
• The replay that matters most: the checker as it now stands and the checker as it was before either review round, both run over every review this repository has ever received — the 78 PRs that carry one. Both return green on exactly the same 38. Two rounds of fixes changed the verdict on zero real reviews. They closed synthetic holes without touching the habit the rule was measured against.

⚠️ A limitation of this round, for @astubbs

This reviewer reports that its Bash tool refused every attempt to execute anything — bin/test-check-human-lgtm.sh, a scratch repro, even a bare python3 -c. So a PR that is entirely shell scripts and their self-tests got a static-only review. It still found a real bug that way, which is to its credit, but it could not run the suite, could not confirm its own repro, and could not check the sabotage claims — the three things most worth checking here. bin/AGENTS.md grants bin/check-*.sh and bin/test-check-*.sh to the reviewer by pattern, so the intent is clearly that these are runnable; something in the session's --allowedTools is not honouring it. Worth fixing before the next shell-heavy PR, and not something this PR should change.

[chatgpt-codex-connector]

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: a04a9cfcf3

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

• Open a pull request for review
• Mark a draft as ready
• Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

[chatgpt-codex-connector]

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: f215d3f87f

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

• Open a pull request for review
• Mark a draft as ready
• Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

[chatgpt-codex-connector]

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: e72b72eed7

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

• Open a pull request for review
• Mark a draft as ready
• Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

[chatgpt-codex-connector]

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: a6ab0f6980

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

• Open a pull request for review
• Mark a draft as ready
• Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

[chatgpt-codex-connector]

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: ea6b45df7e

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

• Open a pull request for review
• Mark a draft as ready
• Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

[chatgpt-codex-connector]

💡 Codex Review

Here are some automated review suggestions for this pull request.

Reviewed commit: bbc5f886b6

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

• Open a pull request for review
• Mark a draft as ready
• Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

[astubbs]

lgtm