Skip to content

logging exceptions#35

Merged
ymatsuda merged 4 commits into
confluentinc:streamingfrom
ymatsuda:streaming
Sep 3, 2015
Merged

logging exceptions#35
ymatsuda merged 4 commits into
confluentinc:streamingfrom
ymatsuda:streaming

Conversation

@ymatsuda

@ymatsuda ymatsuda commented Sep 3, 2015

Copy link
Copy Markdown

Copy link
Copy Markdown

Choose a reason for hiding this comment

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

Do we still need to re-throw in commitAll at all if they are not handled here?

Copy link
Copy Markdown
Author

Choose a reason for hiding this comment

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

commitAll() is also called from onPartitionsRevoked(). I am not sure how KafkaConsumer handles a runtime exception from ConsumerRebalanceCallback.

@guozhangwang

Copy link
Copy Markdown

Could we make the logging message first letter capitalized?

ymatsuda added a commit that referenced this pull request Sep 3, 2015
@ymatsuda ymatsuda merged commit 572d5a2 into confluentinc:streaming Sep 3, 2015
David Arthur (mumrah) pushed a commit that referenced this pull request Aug 28, 2024
…FoundException (#35) (apache#16919)

This patch updates getOrMaybeCreateClassicGroup to only throw GroupIdNotFoundException as we did for other internal methods. The callers are responsible for translating the error to the appropriate one depending on the context. There is only one case.

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants