[GitHub] [kafka] chia7712 commented on a change in pull request #10269: KAFKA-12410 KafkaAPis ought to group fetch data before generating fet…

chia7712 commented on a change in pull request #10269: URL: https://github.com/apache/kafka/pull/10269#discussion_r589633902 ## File path: core/src/main/scala/kafka/server/KafkaApis.scala ## @@ -3368,8 +3396,16 @@ object KafkaApis { private[server] def

[GitHub] [kafka] chia7712 commented on a change in pull request #10269: KAFKA-12410 KafkaAPis ought to group fetch data before generating fet…

chia7712 commented on a change in pull request #10269: URL: https://github.com/apache/kafka/pull/10269#discussion_r588138822 ## File path: core/src/main/scala/kafka/server/KafkaApis.scala ## @@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,

[GitHub] [kafka] chia7712 commented on a change in pull request #10269: KAFKA-12410 KafkaAPis ought to group fetch data before generating fet…

chia7712 commented on a change in pull request #10269: URL: https://github.com/apache/kafka/pull/10269#discussion_r588095220 ## File path: core/src/main/scala/kafka/server/KafkaApis.scala ## @@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,

[GitHub] [kafka] chia7712 commented on a change in pull request #10269: KAFKA-12410 KafkaAPis ought to group fetch data before generating fet…

chia7712 commented on a change in pull request #10269: URL: https://github.com/apache/kafka/pull/10269#discussion_r588094923 ## File path: core/src/main/scala/kafka/server/KafkaApis.scala ## @@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,

[GitHub] [kafka] chia7712 commented on a change in pull request #10269: KAFKA-12410 KafkaAPis ought to group fetch data before generating fet…

chia7712 commented on a change in pull request #10269: URL: https://github.com/apache/kafka/pull/10269#discussion_r588091547 ## File path: core/src/main/scala/kafka/server/KafkaApis.scala ## @@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,

[GitHub] [kafka] chia7712 commented on a change in pull request #10269: KAFKA-12410 KafkaAPis ought to group fetch data before generating fet…

chia7712 commented on a change in pull request #10269: URL: https://github.com/apache/kafka/pull/10269#discussion_r588090869 ## File path: core/src/main/scala/kafka/server/KafkaApis.scala ## @@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,

[GitHub] [kafka] chia7712 commented on a change in pull request #10269: KAFKA-12410 KafkaAPis ought to group fetch data before generating fet…

chia7712 commented on a change in pull request #10269: URL: https://github.com/apache/kafka/pull/10269#discussion_r588050163 ## File path: core/src/main/scala/kafka/server/KafkaApis.scala ## @@ -795,7 +795,17 @@ class KafkaApis(val requestChannel: RequestChannel, // the

[GitHub] [kafka] chia7712 commented on a change in pull request #10269: KAFKA-12410 KafkaAPis ought to group fetch data before generating fet…

chia7712 commented on a change in pull request #10269: URL: https://github.com/apache/kafka/pull/10269#discussion_r588049874 ## File path: core/src/main/scala/kafka/server/FetchSession.scala ## @@ -294,14 +294,24 @@ trait FetchContext extends Logging { */ def

[GitHub] [kafka] chia7712 commented on a change in pull request #10269: KAFKA-12410 KafkaAPis ought to group fetch data before generating fet…

chia7712 commented on a change in pull request #10269: URL: https://github.com/apache/kafka/pull/10269#discussion_r588049196 ## File path: core/src/main/scala/kafka/server/FetchSession.scala ## @@ -411,54 +436,40 @@ class IncrementalFetchContext(private val time: Time, }