TaiJuWu commented on code in PR #17559:
URL: https://github.com/apache/kafka/pull/17559#discussion_r1826456416
##########
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java:
##########
@@ -829,7 +829,8 @@ public void assign(Collection<TopicPartition> partitions) {
* topic (per {@link
org.apache.kafka.common.internals.Topic#validate(String)})
* @throws org.apache.kafka.common.errors.UnsupportedVersionException if
the consumer attempts to fetch stable offsets
* when the broker doesn't support this feature
- * @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 classicKafkaConsumer and this
Review Comment:
You are right, thanks!
--
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]
