Kafka 2257#1

Closed

Geoff (granders) wants to merge 23 commits into

Commits on Jul 13, 2015

First commit for replacement for replication test suite. All are currently functional except for "soft failures" simulating gc pauses. The trouble here is that SIGCONT does not restart the broker.
Geoff Anderson
committed

Commits on Jul 14, 2015

Fixed soft failure tests.
Geoff Anderson
committed
Produce/consume from multiple topics.
Geoff Anderson
committed
Added one test with acks=1 and one using compression.
Geoff Anderson
committed
Replaced previous replication_test.py with the new suite of replication tests.
Geoff Anderson
committed

Commits on Jul 20, 2015

Merged in KAFKA-2276
Geoff Anderson
committed

Commits on Jul 22, 2015

Merged in KAFKA-2276
Geoff Anderson
committed

Commits on Jul 23, 2015

Update provisioning so that iptables can be used in creating network partitions.
Geoff Anderson
committed

Commits on Jul 27, 2015

Merged in upstream trunk.
Geoff Anderson
committed
fixed checkstyle errors
Geoff Anderson
committed

Commits on Jul 28, 2015

Many small changes per review. Also, improved performance by making kafka/zk start asynchronous.
Geoff Anderson
committed
Fixed command adding LOG_DIR to env before starting kafka
Geoff Anderson
committed
KAFKA-2301: Warn ConsumerOffsetChecker as deprecated; reviewed by Ewen Cheslack-Postava and Guozhang Wang

Ashish Singh
authored and
Guozhang Wang (guozhangwang)
committed
KAFKA-2381: Fix concurrent modification on assigned partition while looping over it; reviewed by Jason Gustafson, Aditya Auradkar, Ewen Cheslack-Postava, Ismael Juma and Guozhang Wang

Ashish Singh
authored and
Guozhang Wang (guozhangwang)
committed
KAFKA-2347: Add setConsumerRebalanceListener method to ZookeeperConsumerConnector java api; reviewed by Jiangjie Qin, Ismael Juma, Grant Henke and Guozhang Wang

Ashish Singh
authored and
Guozhang Wang (guozhangwang)
committed
KAFKA-2275: Add ListTopics() API to the Java consumer; reviewed by Jason Gustafson, Edward Ribeiro and Guozhang Wang

Ashish Singh
authored and
Guozhang Wang (guozhangwang)
committed
KAFKA-2089: Fix transient MetadataTest failure; reviewed by Jiangjie Qin and Guozhang Wang

Rajini Sivaram (rajinisivaram)
authored and
Guozhang Wang (guozhangwang)
committed

Commits on Jul 29, 2015

Merged in upstream trunk.
Geoff Anderson
committed
Fixed some of the wait_until conditions which were causing problems with broker restarts.
Geoff Anderson
committed
Merged in final KAFKA-2276
Geoff Anderson
committed
Added unit-test-like sanity checks to help with validating and debugging Service subclasses (etc.)
Geoff Anderson
committed
Added crude network partition test which approximately replicates the conditions of the Jepsen blog post, and validates that failure does indeed occur
Geoff Anderson
committed
Added check in kafka.stop_node to kill -9 if SIGTERM did not work.
Geoff Anderson
committed