|
|
|
KAFKA-2745
|
KAFKA-1326
Update JavaDoc for the new / updated APIs
|
Guozhang Wang
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2720
|
KAFKA-1326
Periodic purging groups in the coordinator
|
Jason Gustafson
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2698
|
KAFKA-1326
add paused API
|
Jason Gustafson
|
Onur Karaman
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2697
|
KAFKA-1326
add leave group logic to the consumer
|
Jason Gustafson
|
Onur Karaman
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2655
|
KAFKA-1326
Consumer.poll(0)'s overhead too large
|
Jason Gustafson
|
Guozhang Wang
|
|
Resolved |
Not A Problem
|
|
|
|
|
|
|
|
KAFKA-2632
|
KAFKA-1326
Move fetchable check from fetchedRecords to fetch response handler
|
Guozhang Wang
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2604
|
KAFKA-1326
Remove `completeAll` and improve timeout passed to `Selector.poll` from `NetworkClient.poll`
|
Ismael Juma
|
Ismael Juma
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2515
|
KAFKA-1326
handle oversized messages properly in new consumer
|
Guozhang Wang
|
Jun Rao
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2491
|
KAFKA-1326
Update ErrorMapping with New Consumer Errors
|
Jason Gustafson
|
Jason Gustafson
|
|
Resolved |
Not A Problem
|
|
|
|
|
|
|
|
KAFKA-2490
|
KAFKA-1326
support new consumer in ConsumerGroupCommand
|
Ashish Singh
|
Jun Rao
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2487
|
KAFKA-1326
change kafka.examples.Consumer to use the new java consumer
|
Ashish Singh
|
Jun Rao
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2486
|
KAFKA-1326
New consumer performance
|
Jason Gustafson
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2464
|
KAFKA-1326
Client-side assignment and group generalization
|
Jason Gustafson
|
Jason Gustafson
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2453
|
KAFKA-1326
enable new consumer in EndToEndLatency
|
Ben Stopford
|
Jun Rao
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2452
|
KAFKA-1326
enable new consumer in mirror maker
|
Jiangjie Qin
|
Jun Rao
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2397
|
KAFKA-1326
leave group request
|
Onur Karaman
|
Onur Karaman
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2275
|
KAFKA-1326
Add a ListTopics() API to the new consumer
|
Ashish Singh
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2274
|
KAFKA-1326
Add integration test for consumer coordinator
|
Jason Gustafson
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2273
|
KAFKA-1326
KIP-54: Add rebalance with a minimal number of reassignments to server-defined strategy list
|
Vahid Hashemian
|
Olof Johansson
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2245
|
KAFKA-1326
Add response tests for ConsumerCoordinator
|
Onur Karaman
|
Onur Karaman
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2239
|
KAFKA-1326
Allow coordinator to aggresively remove group when it is no longer owning the group
|
Guozhang Wang
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2208
|
KAFKA-1326
Consumer should detect coordinator failures
|
Guozhang Wang
|
Onur Karaman
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2168
|
KAFKA-1326
New consumer poll() can block other calls like position(), commit(), and close() indefinitely
|
Jason Gustafson
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2123
|
KAFKA-1326
Make new consumer offset commit API use callback + future
|
Jason Gustafson
|
Ewen Cheslack-Postava
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2076
|
KAFKA-1326
Add an API to new consumer to allow user get high watermark of partitions.
|
Jiangjie Qin
|
Jiangjie Qin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2018
|
KAFKA-1326
Add metadata to consumer registry info
|
Guozhang Wang
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2017
|
KAFKA-1326
Persist Coordinator State for Coordinator Failover
|
Guozhang Wang
|
Onur Karaman
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-2015
|
KAFKA-1326
Enable ConsoleConsumer to use new consumer
|
Ben Stopford
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1925
|
KAFKA-1326
Coordinator Node Id set to INT_MAX breaks coordinator metadata updates
|
Guozhang Wang
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1910
|
KAFKA-1326
Refactor KafkaConsumer
|
Guozhang Wang
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1893
|
KAFKA-1326
Allow regex subscriptions in the new consumer
|
Ashish Singh
|
Jay Kreps
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1892
|
KAFKA-1326
System tests for the new consumer and co-ordinator
|
Guozhang Wang
|
Jay Kreps
|
|
Resolved |
Won't Fix
|
|
|
|
|
|
|
|
KAFKA-1760
|
KAFKA-1326
Implement new consumer client
|
Jay Kreps
|
Jay Kreps
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1740
|
KAFKA-1326
Merge Offset manager into Coordinator
|
Guozhang Wang
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1462
|
KAFKA-1326
Add new request and response formats for the new consumer and coordinator communication
|
Jun Rao
|
Guozhang Wang
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1335
|
KAFKA-1326
Add rebalancing logic to the coordinator / consumer
|
Guozhang Wang
|
Neha Narkhede
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1334
|
KAFKA-1326
Coordinator should detect consumer failures
|
Onur Karaman
|
Neha Narkhede
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1333
|
KAFKA-1326
Add consumer co-ordinator module to the server
|
Guozhang Wang
|
Neha Narkhede
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1332
|
KAFKA-1326
Add functionality to the offsetsBeforeTime() API
|
Jason Gustafson
|
Neha Narkhede
|
|
Resolved |
Duplicate
|
|
|
|
|
|
|
|
KAFKA-1331
|
KAFKA-1326
Add ability to commit offsets to the new consumer
|
Jay Kreps
|
Neha Narkhede
|
|
Resolved |
Duplicate
|
|
|
|
|
|
|
|
KAFKA-1330
|
KAFKA-1326
Implement subscribe(TopicPartition...partitions) and pool(timeout) in the consumer
|
Jay Kreps
|
Neha Narkhede
|
|
Resolved |
Duplicate
|
|
|
|
|
|
|
|
KAFKA-1329
|
KAFKA-1326
Add metadata fetch and refresh functionality to the consumer
|
Neha Narkhede
|
Neha Narkhede
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1328
|
KAFKA-1326
Add new consumer APIs
|
Neha Narkhede
|
Neha Narkhede
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
KAFKA-1316
|
KAFKA-1326
Refactor Sender
|
Jay Kreps
|
Jay Kreps
|
|
Resolved |
Fixed
|
|
|
|
|