[GitHub] [kafka] RivenSun2 commented on a change in pull request #11460: KAFKA-13425: Optimization of KafkaConsumer#pause semantics

2021-11-04 Thread GitBox
RivenSun2 commented on a change in pull request #11460: URL: https://github.com/apache/kafka/pull/11460#discussion_r742601310 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java ## @@ -326,6 +330,10 @@ private Exception invo

[GitHub] [kafka] RivenSun2 commented on a change in pull request #11460: KAFKA-13425: Optimization of KafkaConsumer#pause semantics

2021-11-04 Thread GitBox
RivenSun2 commented on a change in pull request #11460: URL: https://github.com/apache/kafka/pull/11460#discussion_r742589702 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java ## @@ -307,6 +307,10 @@ private Exception invo

[GitHub] [kafka] RivenSun2 commented on a change in pull request #11460: KAFKA-13425: Optimization of KafkaConsumer#pause semantics

2021-11-04 Thread GitBox
RivenSun2 commented on a change in pull request #11460: URL: https://github.com/apache/kafka/pull/11460#discussion_r742589553 ## File path: clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java ## @@ -2007,7 +2007,7 @@ public OffsetAndMetadata committed(To