lianetm commented on code in PR #17559:
URL: https://github.com/apache/kafka/pull/17559#discussion_r1829354575
##########
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java:
##########
@@ -873,7 +873,8 @@ public ConsumerRecords<K, V> poll(final Duration timeout) {
* is too large or if the topic does not exist).
* @throws org.apache.kafka.common.errors.TimeoutException if the timeout
specified by {@code default.api.timeout.ms} expires
* before successful completion of the offset commit
- * @throws org.apache.kafka.common.errors.FencedInstanceIdException if
this consumer instance gets fenced by broker.
+ * @throws org.apache.kafka.common.errors.FencedInstanceIdException if
this consumer is using the classic group protocol
Review Comment:
you're right! that was me reading the func name on top of the doc (instead
of the one below), my bad, all good.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
