appchemist commented on code in PR #15961:
URL: https://github.com/apache/kafka/pull/15961#discussion_r1602392678
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##########
@@ -1607,6 +1607,7 @@ private Fetch<K, V> pollForFetches(Timer timer) {
wakeupTrigger.clearTask();
}
+ metadata.maybeThrowAnyException();
Review Comment:
Thank you for review. @lianetm
I learned a lot from it.
It seems that we can solve the wiring issue using MetadataUpdater in this
case.
What do you think?
I need more time for this issue and I don't think we have a lot of time left
for this issue because it's a blocker.
so it's fine if you hand it off to someone else.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
