Public signup for this instance is disabled. Go to our Self serve sign up page to request an account. Report potential security issues privately

  1. Sub-task KAFKA-18392
    Require client-generated member IDs for ShareGroupHeartbeat
  2. Sub-task KAFKA-18312
    Add "entityType": "topicName" to "SubscribedTopicNames" in ShareGroupHeartbeatRequest.json
  3. Sub-task KAFKA-18273
    Implement kafka-share-groups.sh --describe --verbose
  4. Sub-task KAFKA-18265
    Optimizing SharePartition locking to improve fetch speed
  5. Sub-task KAFKA-18260
    Add integration test to ShareConsumerTest for share.auto.offset.reset=by_duration
  6. Sub-task KAFKA-18232
    Prune share state topic metrics
  7. Sub-task KAFKA-18220
    Refactor AsyncConsumerMetrics so they are appropriate for share consumers
  8. Sub-task KAFKA-18205
    Refactor share coordinator and related classes for better readability and organization
  9. Sub-task KAFKA-18198
    Disallow piggyback acknowledgments on initial ShareFetchRequest.
  10. Sub-task KAFKA-18197
    Check if nodeToSend is null before sending ShareAcknowledge.
  11. Sub-task KAFKA-18170
    Periodic snapshots for cold share partitions
  12. Sub-task KAFKA-18165
    Update nodesWithPendingRequests only when a request successfully builds
  13. Sub-task KAFKA-18164
    Empty in memory acknowledgements when a shareAcknowledge request fails
  14. Sub-task KAFKA-18155
    Fix bug in response handler for ShareAcknowledge in clients.
  15. Sub-task KAFKA-18148
    the persister methods deleteState, initializeState, and readSummary should not declare exceptions in their method signatures
  16. Sub-task KAFKA-18129
    `SharePartition#maybeInitialize` should complete the future outsize the write lock
  17. Sub-task KAFKA-18122
    Add ShareConsumeBenchWorker for running trogdor workloads.
  18. Sub-task KAFKA-18121
    Add support for duration-based offset reset strategy
  19. Sub-task KAFKA-18090
    Create specific classes for share group members and assignments
  20. Sub-task KAFKA-18086
    Enable propagation of the error message when writing state
  21. Sub-task KAFKA-18084
    Null and leaked AcquisitionLockTimerTask causes hanging AcknowledgeRequest and corrupted state of batch
  22. Sub-task KAFKA-18079
    `consumer-config` does not work with console-share-consumer
  23. Sub-task KAFKA-18058
    Integrate offset cleanup algorithm with share coordinator
  24. Sub-task KAFKA-18057
    Algorithm to calculate redundant interval of offsets for cleanup
  25. Sub-task KAFKA-18056
    Fix a bug related to updating the callbacks after commitAsync.
  26. Sub-task KAFKA-18022
    fetchOffsetMetadata handling for minBytes estimation in both common/uncommon cases of share fetch
  27. Sub-task KAFKA-18018
    Consumption degrading when using DefaultStatePersister for 1 million records of size 1KB
  28. Sub-task KAFKA-18016
    Fix bugs in handling piggyback acknowledgements in ShareFetch
  29. Sub-task KAFKA-18009
    Remove spurious public constructor for KafkaShareConsumer
  30. Sub-task KAFKA-17991
    Timed calls to future.get in DefaultStatePersister and test improvements
  31. Sub-task KAFKA-17985
    Set default value for share.auto.offset.reset in ShareRoundTripWorker.
  32. Sub-task KAFKA-17970
    Move some purgatory classes from core to share
  33. Sub-task KAFKA-17968
    Create VerifiableShareConsumer
  34. Sub-task KAFKA-17957
    Console share consumer unable to consume all messages when using multiple brokers
  35. Sub-task KAFKA-17956
    Remove Admin.listShareGroups in favour of Admin.listGroups
  36. Sub-task KAFKA-17951
    Rotate share partitions in share fetch
  37. Sub-task KAFKA-17948
    Potential issue during tryComplete and onComplete simultaneous calls to access global variables
  38. Sub-task KAFKA-17945
    Use leader epoch while calling replicaManager.fetchOffsetForTimestamp in ShareFetchUtils
  39. Sub-task KAFKA-17944
    Add error handling in the cases when replicaManager.fetchOffsetForTimestamp throws an error
  40. Sub-task KAFKA-17943
    Error handling when calling replicaManager.getPartitionOrException
  41. Sub-task KAFKA-17942
    Fix testAcknowledgementCommitCallbackInvalidRecordStateException
  42. Sub-task KAFKA-17933
    Add ShareRoundTripWorker for ShareConsumers.
  43. Sub-task KAFKA-17914
    Refactor ShareCoordinator.partitionFor to use SharePartitionKey argument
  44. Sub-task KAFKA-17912
    Align string conversion of SharePartitionKey
  45. Sub-task KAFKA-17901
    Handle fenced exception while acquiring fetch lock
  46. Sub-task KAFKA-17887
    Handle response log result error in DelayedShareFetch
  47. Sub-task KAFKA-17863
    Align share consumer poll result with record batch boundaries
  48. Sub-task KAFKA-17853
    Console share consumer is not terminated immediately
  49. Sub-task KAFKA-17848
    Resolve reliability issue on the broker post moving delayed share fetch purgatory to ReplicaManager
  50. Sub-task KAFKA-17844
    Add tests and fix to complete share fetch request on exception from manager
Refresh results