-
Notifications
You must be signed in to change notification settings - Fork 165
fixes #329: Committing around transaction markers causes encoder to crash #328
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
- CVE-2020-8908: Files::createTempDir local information disclosure vulnerability #4011 - Only used transitively from tests, and is a deprecated function - google/guava#4011
astubbs
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
good for review
parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/ParallelStreamProcessor.java
Show resolved
Hide resolved
|
Looks good to me. Build failed though. |
|
Failed on Enforcer check: |
New issues with WireMocks dep on Jetty BOM ~v9
…that Especially given we also use dependabot. If anyone is concerned to that level, they can use the plugin in their end user applications.
…e-tg # Conflicts: # pom.xml
# Conflicts: # pom.xml
parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/ParallelStreamProcessor.java
Show resolved
Hide resolved
# Conflicts: # pom.xml
astubbs
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Isolate fix to encoder system only. Makes more sense anyway as the field is what it is - truth. Changing it confuses the truth. And only the encoder needs the virtual representation, which it's more than capable of handling when required.
astubbs
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm
rkolesnev
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
Fixes: #329
Test that committing can happen successfully when the base offset for the commit is adjacent to transaction markers in the input partitions.
The system assumes that the next expected (base committed) offset, will always be 1 offset above the highest succeeded. But tx makers can increase this gap from 1 to potentially much higher.
Blocked by: