Repository navigation

Commits

Commits on Mar 13, 2026
- MINOR : Added close() in ShareConsumeBenchWorker::stop() to handle interrupts cleanly. (#21742)
  ShivsundarR
  authored
  1eda166
Commits on Jan 6, 2026
- MINOR : Tolerate GroupIdNotFoundException in consumer when leaving a group. (#21239)
  ShivsundarR
  authored
  aee7a37
Commits on Dec 2, 2025
- MINOR: Add more unit tests to test GAP Acknowledgements in ShareCompletedFetch (#21044)
  ShivsundarR
  authored
  eac1930
Commits on Nov 20, 2025
- MINOR: Cleanup in ShareConsumerTest (#20940)
  ShivsundarR
  authored
  24b6fc0
- KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer (#19886)
  ShivsundarR
  authored
  64cb839
Commits on Nov 19, 2025
- KAFKA-19896: Use MockTime::sleep in ShareConsumeRequestManagerTest. (#20922)
  ShivsundarR
  authored
  679854c
Commits on Nov 18, 2025
- KAFKA-19767 - Send Share-Fetch one-node at a time for record_limit mode (#20855)
  ShivsundarR
  authored
  108ad6e
Commits on Nov 3, 2025
- KAFKA-18794: Add check to send one ShareFetchEvent per poll in ShareConsumer. (#20794)
  ShivsundarR
  authored
  c5ae7b4
Commits on Oct 29, 2025
- KAFKA-19789: Log an error when we get duplicate acquired offsets in ShareFetchResponse. (#20752)
  ShivsundarR
  authored
  d6728d4
Commits on Oct 14, 2025
- KAFKA-19725: Replace --property with --reader-property in ConsoleProducer (KIP-1147) (#20673)
  ShivsundarR
  authored
  cf18327
Commits on Sep 24, 2025
- MINOR: Add unit tests for verifying --formatter-property in console tools. (#20560)
  ShivsundarR
  authored
  348e64c
Commits on Sep 18, 2025
- MINOR : Fix parantheses in console_consumer.py and console_share_consumer.py (#20552)
  ShivsundarR
  authored
  e647bdc
Commits on Sep 17, 2025
- KAFKA-19623: Implement KIP-1147 for console producer/consumer/share-consumer. (#20479)
  ShivsundarR
  authored
  3bc50f9
Commits on Sep 4, 2025
- MINOR: Use drainEvents() in ShareConsumerImpl::processBackgroundEvents (#20474)
  ShivsundarR
  authored
  29b940b
Commits on Sep 3, 2025
- KAFKA-18220: Refactor AsyncConsumerMetrics to not extend KafkaConsumerMetrics (#20283)
  ShivsundarR
  authored
  d226b43
Commits on Aug 7, 2025
- KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close (#20290)
  ShivsundarR
  authored
  bf42924
Commits on Jul 31, 2025
- KAFKA-19485 (II) : Complete any pending acknowledgements in ShareFetch on an error response. (#20247)
  ShivsundarR
  authored
  e1f4521
Commits on Jul 29, 2025
- KAFKA-19559: Remove ShareFetchMetricsManager sensors on consumer.close() (#20255)
  ShivsundarR
  authored
  40b4fdb
Commits on Jul 10, 2025
- KAFKA-19485: Added check before sending acknowledgements on initial epoch. (#20135)
  ShivsundarR
  authored
  56a3c6d
Commits on Jun 19, 2025
- MINOR : Fix possible flake in ShareConsumerTest:testConsumerCloseInGroupSequential (#19986)
  ShivsundarR
  authored
  5529796
Commits on May 9, 2025
- KAFKA-19229: Ignore background errors while closing share consumers. (Fix flaky test) (#19647)
  ShivsundarR
  authored
  58c0844
Commits on May 4, 2025
- KAFKA-19232: Handle Share session limit reached exception in clients. (#19619)
  ShivsundarR
  authored
  fedbb90
Commits on Apr 15, 2025
- KAFKA-18900: Implement share.acknowledgement.mode to choose acknowledgement mode (#19417)
  ShivsundarR
  authored
  f737ef3
- MINOR: Port changes from KAFKA-18569 for ShareConsumers (#19402)
  ShivsundarR
  authored
  6c3995b
Commits on Apr 11, 2025
- MINOR: Update kafka-console-share-consumer to pass in delivery count. (#19447)
  ShivsundarR
  authored
  88a6402
Commits on Apr 7, 2025
- KAFKA-19084: Port KAFKA-16224, KAFKA-16764 for ShareConsumers (#19369)
  ShivsundarR
  authored
  2d02f1d
Commits on Apr 1, 2025
- MINOR: Add check in ShareConsumerImpl to send acknowledgements of control records when ShareFetch is empty. (#19295)
  ShivsundarR
  authored
  e301508
- KAFKA-19062: Port changes from KAFKA-18645 to share-consumers (#19335)
  ShivsundarR
  authored
  ed77397
Commits on Mar 26, 2025
- KAFKA-18899: Improve handling of timeouts for commitAsync() in ShareConsumer. (#19192)
  
  ShivsundarR
  and
  AndrewJSchofield
  authored
  91758cc
Commits on Feb 25, 2025
- MINOR : Add missing error code in ConsumerHeartbeatRequestManagerTest. (#19024)
  ShivsundarR
  authored
  fae2e53
Commits on Feb 24, 2025
- KAFKA-18779: Validate responses from broker in client for ShareFetch and ShareAcknowledge RPCs. (#18939)
  ShivsundarR
  authored
  2880e04
Commits on Feb 21, 2025
- KAFKA-18033: Remove flaky tag in ShareConsumerTest (#18995)
  ShivsundarR
  authored
  7da1a6c
Commits on Feb 19, 2025
- KAFKA-18829: Added check before converting to IMPLICIT mode (#18964)
  ShivsundarR
  authored
  3603c8f
- KAFKA-18198: Added check to prevent acknowledgements on initial ShareFetchRequest. (#18944)
  ShivsundarR
  authored
  a6a588f
Commits on Feb 12, 2025
- KAFKA-18769: Improve leadership changes handling in ShareConsumeRequestManager. (#18851)
  ShivsundarR
  authored
  0e40b80

Branch selector

User selector

Datepicker

Commit history

Commits on Mar 13, 2026

Commits on Jan 6, 2026

Commits on Dec 2, 2025

Commits on Nov 20, 2025

Commits on Nov 19, 2025

Commits on Nov 18, 2025

Commits on Nov 3, 2025

Commits on Oct 29, 2025

Commits on Oct 14, 2025

Commits on Sep 24, 2025

Commits on Sep 18, 2025

Commits on Sep 17, 2025

Commits on Sep 4, 2025

Commits on Sep 3, 2025

Commits on Aug 7, 2025

Commits on Jul 31, 2025

Commits on Jul 29, 2025

Commits on Jul 10, 2025

Commits on Jun 19, 2025

Commits on May 9, 2025

Commits on May 4, 2025

Commits on Apr 15, 2025

Commits on Apr 11, 2025

Commits on Apr 7, 2025

Commits on Apr 1, 2025

Commits on Mar 26, 2025

Commits on Feb 25, 2025

Commits on Feb 24, 2025

Commits on Feb 21, 2025

Commits on Feb 19, 2025

Commits on Feb 12, 2025