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-16034
    AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id
  2. Sub-task KAFKA-16026
    AsyncConsumer does not send a poll event to the background thread
  3. Sub-task KAFKA-15913
    Migrate AsyncKafkaConsumerTest away from ConsumerTestBuilder
  4. Sub-task KAFKA-15887
    Autocommit during close consistently fails with exception in background thread
  5. Sub-task KAFKA-15865
    Ensure consumer.poll() execute autocommit callback
  6. Sub-task KAFKA-15833
    Restrict Consumer API to be used from one thread
  7. Sub-task KAFKA-15818
    Implement max poll interval
  8. Sub-task KAFKA-15803
    Update last seen epoch during commit
  9. Sub-task KAFKA-15696
    Revoke partitions on Consumer.close()
  10. Sub-task KAFKA-15651
    Investigate auto commit guarantees during Consumer.assign()
  11. Sub-task KAFKA-15562
    Ensure fetch offset and commit offset handler handles both timeout and various error types
  12. Sub-task KAFKA-15555
    Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll()
  13. Sub-task KAFKA-15550
    OffsetsForTimes validation for negative timestamps in new consumer
  14. Sub-task KAFKA-15548
    Send GroupConsumerHeartbeatRequest on Consumer.close()
  15. Sub-task KAFKA-15534
    Propagate client response time when timeout to the request handler
  16. Sub-task KAFKA-15508
    Method always return the same value ApplicationEventProcessor.java
  17. Sub-task KAFKA-15438
    Review exception caching logic used for reset/validate positions in async consumer
  18. Sub-task KAFKA-15317
    Fix for async consumer access to committed offsets with multiple consumers
  19. Sub-task KAFKA-15316
    CommitRequestManager not calling RequestState callbacks
  20. Sub-task KAFKA-15306
    Integrate committed offsets logic when updating fetching positions
  21. Sub-task KAFKA-15304
    CompletableApplicationEvents aren't being completed when the consumer is closing
  22. Sub-task KAFKA-15281
    Implement the groupMetadata Consumer API
  23. Sub-task KAFKA-15277
    Design & implement support for internal Consumer delegates
  24. Sub-task KAFKA-15270
    Integration tests for AsyncConsumer simple consume case
  25. Sub-task KAFKA-15188
    Implement more of the remaining PrototypeAsyncConsumer APIs
  26. Sub-task KAFKA-15184
    New consumer internals refactoring and clean up
  27. Sub-task KAFKA-15180
    Generalize integration tests to change use of KafkaConsumer to Consumer
  28. Sub-task KAFKA-15174
    Ensure the correct thread is executing the callbacks
  29. Sub-task KAFKA-15164
    Extract reusable logic from OffsetsForLeaderEpochClient
  30. Sub-task KAFKA-15163
    Implement validatePositions functionality for new KafkaConsumer
  31. Sub-task KAFKA-15115
    Implement resetPositions functionality in OffsetsRequestManager
  32. Sub-task KAFKA-15081
    Implement new consumer offsetsForTimes
  33. Sub-task KAFKA-14966
    Extract reusable logic from OffsetFetcher
  34. Sub-task KAFKA-14965
    Introduce OffsetsRequestManager to integrate ListOffsets requests into new consumer threading refactor
  35. Sub-task KAFKA-14960
    Metadata Request Manager and listTopics/partitionsFor API
  36. Sub-task KAFKA-14950
    Implement assign() and assignment()
  37. Sub-task KAFKA-14937
    Refactoring for client code to reduce boilerplate
  38. Sub-task KAFKA-14875
    Implement Wakeup()
  39. Sub-task KAFKA-14848
    KafkaConsumer incorrectly passes locally-scoped deserializers to FetchConfig
  40. Sub-task KAFKA-14761
    Integration Tests for the New Consumer Implementation
  41. Sub-task KAFKA-14758
    Extract inner classes from Fetcher for reuse in refactoring
  42. Sub-task KAFKA-14724
    Port tests in FetcherTest to FetchRequestManagerTest
  43. Sub-task KAFKA-14675
    Extract metadata-related tasks from Fetcher into MetadataFetcher
  44. Sub-task KAFKA-14468
    Refactor Commit Logic
  45. Sub-task KAFKA-14365
    Extract common logic from Fetcher
  46. Sub-task KAFKA-14274
    Introduce FetchRequestManager to integrate fetch into new consumer threading refactor
  47. Sub-task KAFKA-14264
    Refactor coordinator code
  48. Sub-task KAFKA-14252
    Create background thread skeleton for new Consumer threading model
  49. Sub-task KAFKA-14247
    Implement EventHandler interface and DefaultEventHandler for Consumer
Refresh results