Bulk Operation

KAFKA-1326 Update JavaDoc for the new / updated APIs

KAFKA-1326 Periodic purging groups in the coordinator

KAFKA-1326 add paused API

KAFKA-1326 add leave group logic to the consumer

KAFKA-1326 Consumer.poll(0)'s overhead too large

KAFKA-1326 Move fetchable check from fetchedRecords to fetch response handler

KAFKA-1326 Remove `completeAll` and improve timeout passed to `Selector.poll` from `NetworkClient.poll`

KAFKA-1326 handle oversized messages properly in new consumer

KAFKA-1326 Update ErrorMapping with New Consumer Errors

KAFKA-1326 support new consumer in ConsumerGroupCommand

KAFKA-1326 change kafka.examples.Consumer to use the new java consumer

KAFKA-1326 New consumer performance

KAFKA-1326 Client-side assignment and group generalization

KAFKA-1326 enable new consumer in EndToEndLatency

KAFKA-1326 enable new consumer in mirror maker

KAFKA-1326 leave group request

KAFKA-1326 Add a ListTopics() API to the new consumer

KAFKA-1326 Add integration test for consumer coordinator

KAFKA-1326 KIP-54: Add rebalance with a minimal number of reassignments to server-defined strategy list

KAFKA-1326 Add response tests for ConsumerCoordinator

KAFKA-1326 Allow coordinator to aggresively remove group when it is no longer owning the group

KAFKA-1326 Consumer should detect coordinator failures

KAFKA-1326 New consumer poll() can block other calls like position(), commit(), and close() indefinitely

KAFKA-1326 Make new consumer offset commit API use callback + future

KAFKA-1326 Add an API to new consumer to allow user get high watermark of partitions.

KAFKA-1326 Add metadata to consumer registry info

KAFKA-1326 Persist Coordinator State for Coordinator Failover

KAFKA-1326 Enable ConsoleConsumer to use new consumer

KAFKA-1326 Coordinator Node Id set to INT_MAX breaks coordinator metadata updates

KAFKA-1326 Refactor KafkaConsumer

KAFKA-1326 Allow regex subscriptions in the new consumer

KAFKA-1326 System tests for the new consumer and co-ordinator

KAFKA-1326 Implement new consumer client

KAFKA-1326 Merge Offset manager into Coordinator

KAFKA-1326 Add new request and response formats for the new consumer and coordinator communication

KAFKA-1326 Add rebalancing logic to the coordinator / consumer

KAFKA-1326 Coordinator should detect consumer failures

KAFKA-1326 Add consumer co-ordinator module to the server

KAFKA-1326 Add functionality to the offsetsBeforeTime() API

KAFKA-1326 Add ability to commit offsets to the new consumer

KAFKA-1326 Implement subscribe(TopicPartition...partitions) and pool(timeout) in the consumer

KAFKA-1326 Add metadata fetch and refresh functionality to the consumer

KAFKA-1326 Add new consumer APIs

KAFKA-1326 Refactor Sender