Commits

Branch selector

 trunk

User selector

ShivsundarR

All time

Commit History

Commits on Mar 13, 2026

• MINOR : Added close() in ShareConsumeBenchWorker::stop() to handle interrupts cleanly. (#21742)

  Show description for 1eda166
  ShivsundarR

  authored
  1eda166

  Copy full SHA for 1eda166

Commits on Jan 6, 2026

• MINOR : Tolerate GroupIdNotFoundException in consumer when leaving a group. (#21239)

  Show description for aee7a37
  ShivsundarR

  authored
  aee7a37

  Copy full SHA for aee7a37

Commits on Dec 2, 2025

• MINOR: Add more unit tests to test GAP Acknowledgements in ShareCompletedFetch (#21044)

  Show description for eac1930
  ShivsundarR

  authored
  eac1930

  Copy full SHA for eac1930

Commits on Nov 20, 2025

• MINOR: Cleanup in ShareConsumerTest (#20940)

  Show description for 24b6fc0
  ShivsundarR

  authored
  24b6fc0

  Copy full SHA for 24b6fc0

• KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer (#19886)

  Show description for 64cb839
  ShivsundarR

  authored
  64cb839

  Copy full SHA for 64cb839

Commits on Nov 19, 2025

• KAFKA-19896: Use MockTime::sleep in ShareConsumeRequestManagerTest. (#20922)

  Show description for 679854c
  ShivsundarR

  authored
  679854c

  Copy full SHA for 679854c

Commits on Nov 18, 2025

• KAFKA-19767 - Send Share-Fetch one-node at a time for record_limit mode (#20855)

  Show description for 108ad6e
  ShivsundarR

  authored
  108ad6e

  Copy full SHA for 108ad6e

Commits on Nov 3, 2025

• KAFKA-18794: Add check to send one ShareFetchEvent per poll in ShareConsumer. (#20794)

  Show description for c5ae7b4
  ShivsundarR

  authored
  c5ae7b4

  Copy full SHA for c5ae7b4

Commits on Oct 29, 2025

• KAFKA-19789: Log an error when we get duplicate acquired offsets in ShareFetchResponse. (#20752)

  Show description for d6728d4
  ShivsundarR

  authored
  d6728d4

  Copy full SHA for d6728d4

Commits on Oct 14, 2025

• KAFKA-19725: Replace --property with --reader-property in ConsoleProducer (KIP-1147) (#20673)

  Show description for cf18327
  ShivsundarR

  authored
  cf18327

  Copy full SHA for cf18327

Commits on Sep 24, 2025

• MINOR: Add unit tests for verifying --formatter-property in console tools. (#20560)

  Show description for 348e64c
  ShivsundarR

  authored
  348e64c

  Copy full SHA for 348e64c

Commits on Sep 18, 2025

• MINOR : Fix parantheses in console_consumer.py and console_share_consumer.py (#20552)

  Show description for e647bdc
  ShivsundarR

  authored
  e647bdc

  Copy full SHA for e647bdc

Commits on Sep 17, 2025

• KAFKA-19623: Implement KIP-1147 for console producer/consumer/share-consumer. (#20479)

  Show description for 3bc50f9
  ShivsundarR

  authored
  3bc50f9

  Copy full SHA for 3bc50f9

Commits on Sep 4, 2025

• MINOR: Use drainEvents() in ShareConsumerImpl::processBackgroundEvents (#20474)

  Show description for 29b940b
  ShivsundarR

  authored
  29b940b

  Copy full SHA for 29b940b

Commits on Sep 3, 2025

• KAFKA-18220: Refactor AsyncConsumerMetrics to not extend KafkaConsumerMetrics (#20283)

  Show description for d226b43
  ShivsundarR

  authored
  d226b43

  Copy full SHA for d226b43

Commits on Aug 7, 2025

• KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close (#20290)

  Show description for bf42924
  ShivsundarR

  authored
  bf42924

  Copy full SHA for bf42924

Commits on Jul 31, 2025

• KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)

  Show description for e1f4521
  ShivsundarR

  authored
  e1f4521

  Copy full SHA for e1f4521

Commits on Jul 29, 2025

• KAFKA-19559: Remove ShareFetchMetricsManager sensors on consumer.close() (#20255)

  Show description for 40b4fdb
  ShivsundarR

  authored
  40b4fdb

  Copy full SHA for 40b4fdb

Commits on Jul 10, 2025

• KAFKA-19485: Added check before sending acknowledgements on initial epoch. (#20135)

  Show description for 56a3c6d
  ShivsundarR

  authored
  56a3c6d

  Copy full SHA for 56a3c6d

Commits on Jun 19, 2025

• MINOR : Fix possible flake in ShareConsumerTest:testConsumerCloseInGroupSequential (#19986)

  Show description for 5529796
  ShivsundarR

  authored
  5529796

  Copy full SHA for 5529796

Commits on May 9, 2025

• KAFKA-19229: Ignore background errors while closing share consumers. (Fix flaky test) (#19647)

  Show description for 58c0844
  ShivsundarR

  authored
  58c0844

  Copy full SHA for 58c0844

Commits on May 4, 2025

• KAFKA-19232: Handle Share session limit reached exception in clients. (#19619)

  Show description for fedbb90
  ShivsundarR

  authored
  fedbb90

  Copy full SHA for fedbb90

Commits on Apr 15, 2025

• KAFKA-18900: Implement share.acknowledgement.mode to choose acknowledgement mode (#19417)

  Show description for f737ef3
  ShivsundarR

  authored
  f737ef3

  Copy full SHA for f737ef3

• MINOR: Port changes from KAFKA-18569 for ShareConsumers (#19402)

  Show description for 6c3995b
  ShivsundarR

  authored
  6c3995b

  Copy full SHA for 6c3995b

Commits on Apr 11, 2025

• MINOR: Update kafka-console-share-consumer to pass in delivery count. (#19447)

  Show description for 88a6402
  ShivsundarR

  authored
  88a6402

  Copy full SHA for 88a6402

Commits on Apr 7, 2025

• KAFKA-19084: Port KAFKA-16224, KAFKA-16764 for ShareConsumers (#19369)

  Show description for 2d02f1d
  ShivsundarR

  authored
  2d02f1d

  Copy full SHA for 2d02f1d

Commits on Apr 1, 2025

• MINOR: Add check in ShareConsumerImpl to send acknowledgements of control records when ShareFetch is empty. (#19295)

  Show description for e301508
  ShivsundarR

  authored
  e301508

  Copy full SHA for e301508

• KAFKA-19062: Port changes from KAFKA-18645 to share-consumers (#19335)

  Show description for ed77397
  ShivsundarR

  authored
  ed77397

  Copy full SHA for ed77397

Commits on Mar 26, 2025

• KAFKA-18899: Improve handling of timeouts for commitAsync() in ShareConsumer. (#19192)

  Show description for 91758cc
  

  ShivsundarR

  and

  AndrewJSchofield

  authored
  91758cc

  Copy full SHA for 91758cc

Commits on Feb 25, 2025

• MINOR : Add missing error code in ConsumerHeartbeatRequestManagerTest. (#19024)

  Show description for fae2e53
  ShivsundarR

  authored
  fae2e53

  Copy full SHA for fae2e53

Commits on Feb 24, 2025

• KAFKA-18779: Validate responses from broker in client for ShareFetch and ShareAcknowledge RPCs. (#18939)

  Show description for 2880e04
  ShivsundarR

  authored
  2880e04

  Copy full SHA for 2880e04

Commits on Feb 21, 2025

• KAFKA-18033: Remove flaky tag in ShareConsumerTest (#18995)

  Show description for 7da1a6c
  ShivsundarR

  authored
  7da1a6c

  Copy full SHA for 7da1a6c

Commits on Feb 19, 2025

• KAFKA-18829: Added check before converting to IMPLICIT mode (#18964)

  Show description for 3603c8f
  ShivsundarR

  authored
  3603c8f

  Copy full SHA for 3603c8f

• KAFKA-18198: Added check to prevent acknowledgements on initial ShareFetchRequest. (#18944)

  Show description for a6a588f
  ShivsundarR

  authored
  a6a588f

  Copy full SHA for a6a588f

Commits on Feb 12, 2025

• KAFKA-18769: Improve leadership changes handling in ShareConsumeRequestManager. (#18851)

  Show description for 0e40b80
  ShivsundarR

  authored
  0e40b80

  Copy full SHA for 0e40b80