[GitHub] [kafka] rajinisivaram commented on a change in pull request #9434: MINOR: Handle lastFetchedEpoch/divergingEpoch in FetchSession and DelayedFetch

rajinisivaram commented on a change in pull request #9434: URL: https://github.com/apache/kafka/pull/9434#discussion_r505716961 ## File path: core/src/main/scala/kafka/server/FetchSession.scala ## @@ -77,7 +77,8 @@ class CachedPartition(val topic: String,

[GitHub] [kafka] rajinisivaram commented on a change in pull request #9434: MINOR: Handle lastFetchedEpoch/divergingEpoch in FetchSession and DelayedFetch

rajinisivaram commented on a change in pull request #9434: URL: https://github.com/apache/kafka/pull/9434#discussion_r505716802 ## File path: core/src/main/scala/kafka/cluster/Partition.scala ## @@ -1162,6 +1162,13 @@ class Partition(val topicPartition: TopicPartition, loc

[GitHub] [kafka] rajinisivaram commented on a change in pull request #9434: MINOR: Handle lastFetchedEpoch/divergingEpoch in FetchSession and DelayedFetch

rajinisivaram commented on a change in pull request #9434: URL: https://github.com/apache/kafka/pull/9434#discussion_r505698143 ## File path: core/src/main/scala/kafka/cluster/Partition.scala ## @@ -1162,6 +1162,13 @@ class Partition(val topicPartition: TopicPartition, loc

[GitHub] [kafka] rajinisivaram commented on a change in pull request #9434: MINOR: Handle lastFetchedEpoch/divergingEpoch in FetchSession and DelayedFetch

rajinisivaram commented on a change in pull request #9434: URL: https://github.com/apache/kafka/pull/9434#discussion_r504954049 ## File path: core/src/main/scala/kafka/server/DelayedFetch.scala ## @@ -88,6 +90,13 @@ class DelayedFetch(delayMs: Long, try { if

[GitHub] [kafka] rajinisivaram commented on a change in pull request #9434: MINOR: Handle lastFetchedEpoch/divergingEpoch in FetchSession and DelayedFetch

rajinisivaram commented on a change in pull request #9434: URL: https://github.com/apache/kafka/pull/9434#discussion_r504952903 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1084,7 +1084,7 @@ class ReplicaManager(val config: KafkaConfig, fetc