Bulk Operation

KAFKA-16092 Require client-generated member IDs for ShareGroupHeartbeat

KAFKA-16092 Add "entityType": "topicName" to "SubscribedTopicNames" in ShareGroupHeartbeatRequest.json

KAFKA-16092 Implement kafka-share-groups.sh --describe --verbose

KAFKA-16092 Optimizing SharePartition locking to improve fetch speed

KAFKA-16092 Add integration test to ShareConsumerTest for share.auto.offset.reset=by_duration

KAFKA-16092 Prune share state topic metrics

KAFKA-16092 Refactor AsyncConsumerMetrics so they are appropriate for share consumers

KAFKA-16092 Refactor share coordinator and related classes for better readability and organization

KAFKA-16092 Disallow piggyback acknowledgments on initial ShareFetchRequest.

KAFKA-16092 Check if nodeToSend is null before sending ShareAcknowledge.

KAFKA-16092 Periodic snapshots for cold share partitions

KAFKA-16092 Update nodesWithPendingRequests only when a request successfully builds

KAFKA-16092 Empty in memory acknowledgements when a shareAcknowledge request fails

KAFKA-16092 Fix bug in response handler for ShareAcknowledge in clients.

KAFKA-16092 the persister methods deleteState, initializeState, and readSummary should not declare exceptions in their method signatures

KAFKA-16092 `SharePartition#maybeInitialize` should complete the future outsize the write lock

KAFKA-16092 Add ShareConsumeBenchWorker for running trogdor workloads.

KAFKA-16092 Add support for duration-based offset reset strategy

KAFKA-16092 Create specific classes for share group members and assignments

KAFKA-16092 Enable propagation of the error message when writing state

KAFKA-16092 Null and leaked AcquisitionLockTimerTask causes hanging AcknowledgeRequest and corrupted state of batch

KAFKA-16092 `consumer-config` does not work with console-share-consumer

KAFKA-16092 Integrate offset cleanup algorithm with share coordinator

KAFKA-16092 Algorithm to calculate redundant interval of offsets for cleanup

KAFKA-16092 Fix a bug related to updating the callbacks after commitAsync.

KAFKA-16092 fetchOffsetMetadata handling for minBytes estimation in both common/uncommon cases of share fetch

KAFKA-16092 Consumption degrading when using DefaultStatePersister for 1 million records of size 1KB

KAFKA-16092 Fix bugs in handling piggyback acknowledgements in ShareFetch

KAFKA-16092 Remove spurious public constructor for KafkaShareConsumer

KAFKA-16092 Timed calls to future.get in DefaultStatePersister and test improvements

KAFKA-16092 Set default value for share.auto.offset.reset in ShareRoundTripWorker.

KAFKA-16092 Move some purgatory classes from core to share

KAFKA-16092 Create VerifiableShareConsumer

KAFKA-16092 Console share consumer unable to consume all messages when using multiple brokers

KAFKA-16092 Remove Admin.listShareGroups in favour of Admin.listGroups

KAFKA-16092 Rotate share partitions in share fetch

KAFKA-16092 Potential issue during tryComplete and onComplete simultaneous calls to access global variables

KAFKA-16092 Use leader epoch while calling replicaManager.fetchOffsetForTimestamp in ShareFetchUtils

KAFKA-16092 Add error handling in the cases when replicaManager.fetchOffsetForTimestamp throws an error

KAFKA-16092 Error handling when calling replicaManager.getPartitionOrException

KAFKA-16092 Fix testAcknowledgementCommitCallbackInvalidRecordStateException

KAFKA-16092 Add ShareRoundTripWorker for ShareConsumers.

KAFKA-16092 Refactor ShareCoordinator.partitionFor to use SharePartitionKey argument

KAFKA-16092 Align string conversion of SharePartitionKey

KAFKA-16092 Handle fenced exception while acquiring fetch lock

KAFKA-16092 Handle response log result error in DelayedShareFetch

KAFKA-16092 Align share consumer poll result with record batch boundaries

KAFKA-16092 Console share consumer is not terminated immediately

KAFKA-16092 Resolve reliability issue on the broker post moving delayed share fetch purgatory to ReplicaManager

KAFKA-16092 Add tests and fix to complete share fetch request on exception from manager

KAFKA-16092 Verify ShareFetch requests return a completed/erroneous future on purgatory close

KAFKA-16092 Handle acknowledgements when subscription changes.

KAFKA-16092 Fix flaky test: testExplicitAcknowledgementCommitAsync

KAFKA-16092 Persist higher leaderEpoch in read state calls to the share coordinator.

KAFKA-16092 Remove sharePartition from SharePartitionManager if the partition is deleted or becomes a follower

KAFKA-16092 Add capability for max fetch records in share fetch

KAFKA-16092 Remove unnecessary ignorable annotations from RPC schemas

KAFKA-16092 Add dynamic share group configurations group.share.heartbeat.interval.ms and group.share.session.timeout.ms

KAFKA-16092 Add minBytes implementation to DelayedShareFetch

KAFKA-16092 Move DelayedShareFetchPurgatory declaration to ReplicaManager

KAFKA-16092 Clients - resolve race condition for SubscriptionState in share group consumer

KAFKA-16092 Minor tidying of ShareConsumeRequestManager

KAFKA-16092 Move DelayedActionsQueue outside DelayedShareFetch

KAFKA-16092 Generate ShareAcknowledgeCommitCallbackEvent only when the callback is configured.

KAFKA-16092 Tighten up wakeup handling for share consumer

KAFKA-16092 Implement formatter for share group state topic records

KAFKA-16092 Move common fetch related classes from storage to server-common

KAFKA-16092 Simplify share partition acquire API

KAFKA-16092 Get rid of fetch queue in SharePartitionManager

KAFKA-16092 Add a log message for KafkaShareConsumer early access

KAFKA-16092 Improve handling of delivery count

KAFKA-16092 Implement registerMetricsForSubscription

KAFKA-16092 Restructure Share Group Configs

KAFKA-16092 Share partition acquire() need not return a future

KAFKA-16092 Refactor code between SharePartitionManager and DelayedShareFetch for share partition initialization

KAFKA-16092 Introduce a delayed action queue to complete purgatory actions outside purgatory code.

KAFKA-16092 Modify handling of commitSync() in ShareConsumeRequestManager

KAFKA-16092 NOT_LEADER_OR_FOLLOWER with metadata redirection in share group response

KAFKA-16092 Complete pending fetch request on broker shutdown

KAFKA-16092 Make share partition initialization async

KAFKA-16092 Move appropriate classes and interfaces to the new share module

KAFKA-16092 Optimise the handler methods in ShareConsumeRequestManager.

KAFKA-16092 Changed fetch queue processing to reduce the no. of locking and unlocking activity

KAFKA-16092 Create a tool to manipulate share-group state snapshots for recovery purposes

KAFKA-16092 Implement persister error handling and make write calls async

KAFKA-16092 Improve coexistence of consumer groups and share groups

KAFKA-16092 Add config for purge interval for Share Fetch Purgatory

KAFKA-16092 Introduce a purgatory to deal with share fetch requests that cannot be completed instantaneously

KAFKA-16092 Fix releasing of session on clients final epoch

KAFKA-16092 Initial performance testing fixes

KAFKA-16092 Add delivery count to kafka-console-share-consumer.sh

KAFKA-16092 Add share coordinator implementation

KAFKA-16092 Validate compacted topics start offset handling in Share Partition

KAFKA-16092 Improve kafka-share-groups.sh --describe output for empty groups

KAFKA-16092 Refactor Share Sesssion Class to Server Module

KAFKA-16092 Move common coordinator code from group-coordinator into separate module coordinator-common

KAFKA-16092 Refactor consumer heartbeat managers

KAFKA-16092 Introduce share-coordinator module and add resources

KAFKA-16092 Implement DefaultShareStatePersister

KAFKA-16092 Clients : Revisit result handling in ShareConsumeRequestManager

KAFKA-16092 Introduce ConsumerRecord.deliveryCount() and remove deprecations

KAFKA-16092 Add SHARE to group.coordinator.rebalance.protocols

KAFKA-16092 Add integration test for share group list and describe admin calls

KAFKA-16092 Add integration test for ShareGroupFetch/Acknowledge requests

KAFKA-16092 Add integration test for ShareGroupDescribe requests

KAFKA-16092 Remove tracking member partition epoch for share groups

KAFKA-16092 Add integration test for KafkaShareConsumer

KAFKA-16092 Add integration test for Share Group heartbeat

KAFKA-16092 Revised share group record schemas

KAFKA-16092 Share consumer node latency metrics

KAFKA-16092 Refactor consumer membership managers

KAFKA-16092 Clients : Optimise batching of requests per node in ShareConsumeRequestManager

KAFKA-16092 Broker fixes for smooth concurrent fetches on share partition

KAFKA-16092 Retract v6 of ListGroups RPC added in error

KAFKA-16092 Add check for whether the requested partition exists or not in Share Fetch request

KAFKA-16092 hande piggybacked acknowledgements asynchronously in Share Fetch and properly combine the results of fetch and acknowledge

KAFKA-16092 SharePartition - Add more unit tests

KAFKA-16092 Refactor Consumer group and shared classes with Share to modern package

KAFKA-16092 FindCoordinator v6 initial implementation

KAFKA-16092 Implement updateCacheAndOffsets functionality on LSO movement

KAFKA-16092 MINOR: Remove extra synchronized blocks in SharePartitionManager

KAFKA-16092 Implement SharePartitionManager close functionality

KAFKA-16092 Integrate partition leader epoch in Share Partition

KAFKA-16092 Integrate persister read API in Partition leader initilization

KAFKA-16092 Define Persister and Share Coordinator RPCs

KAFKA-16092 Add Share Group dynamic and broker configs

KAFKA-16092 Define group.version=2

KAFKA-16092 Abstract consumer group in coordinator to share functionality with share group

KAFKA-16092 Implement max delivery count functionality in SharePartition

KAFKA-16092 Implement lock timeout functionality in SharePartition

KAFKA-16092 Implement release acquired records functionality in SharePartition

KAFKA-16092 Implement acknowledge functionality in SharePartition

KAFKA-16092 Implement acquire functionality in SharePartition

KAFKA-16092 Implement release acquired records in SharePartitionManager

KAFKA-16092 Implement acknowledge API in SharePartitionManager

KAFKA-16092 Implement share fetch messages

KAFKA-16092 Implement share response handling in SharePartitionManager

KAFKA-16092 Implement share sessions and context

KAFKA-16092 Add support for share acknowledgement request in KafkaApis

KAFKA-16092 Add support for share fetch request in KafkaApis

KAFKA-16092 Add support for share group describe in KafkaApis

KAFKA-16092 Add support for share group heartbeat in KafkaApis

KAFKA-16092 Add ShareGroupDescribe API support in GroupCoordinator

KAFKA-16092 Add ShareGroupHeartbeat API support in GroupCoordinator

KAFKA-16092 Define skeleton for SharePartitionManager and SharePartition

KAFKA-16092 Add support for formatting records written to share-group state topic in kafka-dump-log.sh

KAFKA-16092 Add support for formatting new records written to offsets topic in kafka-dump-log.sh

KAFKA-16092 Investigate missing values for share-coordinator-metrics and share-group-metrics in the broker

KAFKA-16092 Support for share-group-metrics in the broker

KAFKA-16092 Initial code for share-group consumer

KAFKA-16092 Support for read-committed isolation level

KAFKA-16092 Add dynamic group configuration for heartbeat interval and session timeout

KAFKA-16092 Add dynamic group configuration for record lock duration

KAFKA-16092 Add dynamic group configuration for offset reset

KAFKA-16092 Add broker configurations

KAFKA-16092 Add new options for kafka-producer-perf-test.sh

KAFKA-16092 Add kafka-console-share-consumer.sh

KAFKA-16092 Add ConsumerGroupPartitionAssignor interface

KAFKA-16092 Add exceptions for the new error codes

KAFKA-16092 Add AdminClient.listShareGroupOffsets

KAFKA-16092 Add AdminClient.deleteShareGroups

KAFKA-16092 Add AdminClient.deleteShareGroupOffsets

KAFKA-16092 Add AdminClient.alterShareGroupOffsets

KAFKA-16092 Add AdminClient.describeShareGroups and AdminClient.listShareGroups

KAFKA-16092 Create KafkaShareConsumer interface

KAFKA-16092 kafka-share-groups.sh supporting list and describe

KAFKA-16092 Add new RPC definitions