This is an automated email from the ASF dual-hosted git repository.

ijuma pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from e301508b538 MINOR: Add check in ShareConsumerImpl to send 
acknowledgements of control records when ShareFetch is empty.  (#19295)
     add ccf2510fdda MINOR: Remove dead code `maybeWarnIfOversizedRecords` 
(#19316)

No new revisions were added by this update.

Summary of changes:
 .../main/scala/kafka/server/RemoteLeaderEndPoint.scala  |  2 +-
 .../main/scala/kafka/server/ReplicaFetcherManager.scala |  2 +-
 .../main/scala/kafka/server/ReplicaFetcherThread.scala  | 17 ++---------------
 .../unit/kafka/server/ReplicaFetcherThreadTest.scala    | 15 +++++----------
 .../scala/unit/kafka/server/ReplicaManagerTest.scala    |  4 ++--
 .../jmh/fetcher/ReplicaFetcherThreadBenchmark.java      |  3 +--
 6 files changed, 12 insertions(+), 31 deletions(-)

Reply via email to