Bulk Operation

KAFKA-14246 AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id

KAFKA-14246 AsyncConsumer does not send a poll event to the background thread

KAFKA-14246 Migrate AsyncKafkaConsumerTest away from ConsumerTestBuilder

KAFKA-14246 Autocommit during close consistently fails with exception in background thread

KAFKA-14246 Ensure consumer.poll() execute autocommit callback

KAFKA-14246 Restrict Consumer API to be used from one thread

KAFKA-14246 Implement max poll interval

KAFKA-14246 Update last seen epoch during commit

KAFKA-14246 Revoke partitions on Consumer.close()

KAFKA-14246 Investigate auto commit guarantees during Consumer.assign()

KAFKA-14246 Ensure fetch offset and commit offset handler handles both timeout and various error types

KAFKA-14246 Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll()

KAFKA-14246 OffsetsForTimes validation for negative timestamps in new consumer

KAFKA-14246 Send GroupConsumerHeartbeatRequest on Consumer.close()

KAFKA-14246 Propagate client response time when timeout to the request handler

KAFKA-14246 Method always return the same value ApplicationEventProcessor.java

KAFKA-14246 Review exception caching logic used for reset/validate positions in async consumer

KAFKA-14246 Fix for async consumer access to committed offsets with multiple consumers

KAFKA-14246 CommitRequestManager not calling RequestState callbacks

KAFKA-14246 Integrate committed offsets logic when updating fetching positions

KAFKA-14246 CompletableApplicationEvents aren't being completed when the consumer is closing

KAFKA-14246 Implement the groupMetadata Consumer API

KAFKA-14246 Design & implement support for internal Consumer delegates

KAFKA-14246 Integration tests for AsyncConsumer simple consume case

KAFKA-14246 Implement more of the remaining PrototypeAsyncConsumer APIs

KAFKA-14246 New consumer internals refactoring and clean up

KAFKA-14246 Generalize integration tests to change use of KafkaConsumer to Consumer

KAFKA-14246 Ensure the correct thread is executing the callbacks

KAFKA-14246 Extract reusable logic from OffsetsForLeaderEpochClient

KAFKA-14246 Implement validatePositions functionality for new KafkaConsumer

KAFKA-14246 Implement resetPositions functionality in OffsetsRequestManager

KAFKA-14246 Implement new consumer offsetsForTimes

KAFKA-14246 Extract reusable logic from OffsetFetcher

KAFKA-14246 Introduce OffsetsRequestManager to integrate ListOffsets requests into new consumer threading refactor

KAFKA-14246 Metadata Request Manager and listTopics/partitionsFor API

KAFKA-14246 Implement assign() and assignment()

KAFKA-14246 Refactoring for client code to reduce boilerplate

KAFKA-14246 Implement Wakeup()

KAFKA-14246 KafkaConsumer incorrectly passes locally-scoped deserializers to FetchConfig

KAFKA-14246 Integration Tests for the New Consumer Implementation

KAFKA-14246 Extract inner classes from Fetcher for reuse in refactoring

KAFKA-14246 Port tests in FetcherTest to FetchRequestManagerTest

KAFKA-14246 Extract metadata-related tasks from Fetcher into MetadataFetcher

KAFKA-14246 Refactor Commit Logic

KAFKA-14246 Extract common logic from Fetcher

KAFKA-14246 Introduce FetchRequestManager to integrate fetch into new consumer threading refactor

KAFKA-14246 Refactor coordinator code

KAFKA-14246 Create background thread skeleton for new Consumer threading model

KAFKA-14246 Implement EventHandler interface and DefaultEventHandler for Consumer