Skip to content

KAFKA-8040: Streams handle initTransactions timeout#6416

Merged
bbejeck merged 2 commits intoapache:2.0from
vvcephei:KAFKA-8040-streams-retry-initTransactions-2.0-cherry
Mar 11, 2019
Merged

KAFKA-8040: Streams handle initTransactions timeout#6416
bbejeck merged 2 commits intoapache:2.0from
vvcephei:KAFKA-8040-streams-retry-initTransactions-2.0-cherry

Conversation

@vvcephei
Copy link
Copy Markdown
Contributor

@vvcephei vvcephei commented Mar 8, 2019

As of 2.0, Producer.initTransactions may throw a TimeoutException, which is retriable. Streams should retry instead of crashing when we encounter this exception

Reviewers: Guozhang Wang wangguoz@gmail.com, Matthias J. Sax mjsax@apache.org, Bill Bejeck bbejeck@gmail.com

Cherry-pick of #6372

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

As of 2.0, Producer.initTransactions may throw a TimeoutException, which is retriable. Streams should retry instead of crashing when we encounter this exception

Reviewers: Guozhang Wang <wangguoz@gmail.com>, Matthias J. Sax <mjsax@apache.org>,  Bill Bejeck <bbejeck@gmail.com>

See #6372
@vvcephei
Copy link
Copy Markdown
Contributor Author

vvcephei commented Mar 8, 2019

Hey @bbejeck , Here's the cherry-pick of #6372 to 2.0

@bbejeck
Copy link
Copy Markdown
Member

bbejeck commented Mar 9, 2019

@vvcephei failure is related - checkstyle

@bbejeck bbejeck added the streams label Mar 9, 2019
@bbejeck bbejeck requested review from guozhangwang and mjsax March 9, 2019 02:40
@bbejeck
Copy link
Copy Markdown
Member

bbejeck commented Mar 9, 2019

\cc @ableegoldman for review

@guozhangwang
Copy link
Copy Markdown
Contributor

retest this please

Copy link
Copy Markdown
Member

@bbejeck bbejeck left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@bbejeck
Copy link
Copy Markdown
Member

bbejeck commented Mar 9, 2019

@vvcephei just two minor checkstyle failures
StreamTaskTest.java:27:8: Unused import - org.apache.kafka.common.metrics.JmxReporter
LogCaptureAppender.java:21:8: Unused import - org.apache.log4j.Level
Once these are cleaned up we can merge

@vvcephei
Copy link
Copy Markdown
Contributor Author

Oops! Thanks for capturing those, @bbejeck

@bbejeck bbejeck merged commit af7fabc into apache:2.0 Mar 11, 2019
@bbejeck
Copy link
Copy Markdown
Member

bbejeck commented Mar 11, 2019

Merged #6416 into 2.0

@vvcephei
Copy link
Copy Markdown
Contributor Author

Thanks, @bbejeck !

@vvcephei vvcephei deleted the KAFKA-8040-streams-retry-initTransactions-2.0-cherry branch March 11, 2019 22:22
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants