Description
There are duplicate code which try to convert LogReadResult to FetchPartitionData. It seems to me the duplicate code can be eliminated by moving the conversion to LogReadResult.
occurrence 1: https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/ReplicaManager.scala#L1076
occurrence 2:
https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/DelayedFetch.scala#L189
Attachments
Issue Links
- links to