Trunk#42

Closed

SylviaVargasCTL wants to merge 575 commits into0.8.1from

This pull request is big! We're only showing the most recent 250 commits

Commits on Dec 12, 2014

KAFKA-1812 Allow IpV6 in configuration with parseCsvMap patch by Jeff Holoman reviewed by Gwen Shapira and Joe Stein
joestein
committed
kafka-1815; ServerShutdownTest fails in trunk; patched by Chris Cope; reviewed by Jun Rao

Chris Cope
authored and
junrao
committed
kafka-1813; Build fails for scala 2.9.2; patched by Anatoly Fayngelerin; reviewed by Jun Rao

fanatoly
authored and
junrao
committed

Commits on Dec 17, 2014

KAFKA-742: Existing directories under the Kafka data directory without any data cause process to not start; reviewed by Neha Narkhede

Ashish Singh
authored and
nehanarkhede
committed

Commits on Dec 18, 2014

kafka-1797; add the serializer/deserializer api to the new java client; patched by Jun Rao; reviewed by Neha Narkhede
junrao
committed

Commits on Dec 19, 2014

KAFKA-1824 - fix ConsoleProducer so parse.key and key.separator will work again; reviewed by Neha Narkhede

gwenshap
authored and
nehanarkhede
committed

Commits on Dec 24, 2014

KAFKA-1650; (Follow-up patch) to support no data loss in mirror maker; reviewed by Joel Koshy

becketqin
authored and
jjkoshy
committed

Commits on Jan 6, 2015

Commits on Jan 7, 2015

KAFKA-1512 Fixes for limit the maximum number of connections per ip address patch by Jeff Holoman reviewed by Jay Krepps and Gwen Shapira
joestein
committed

Commits on Jan 9, 2015

Commits on Jan 12, 2015

KAFKA-1070 Auto assign broker id; reviewed by Neha Narkhede

Sriharsha Chintalapani
authored and
nehanarkhede
committed
KAFKA-1836 metadata.fetch.timeout.ms set to zero blocks forever; reviewed by Neha Narkhede and Ewen Cheslack-Postava

jaiforums
authored and
nehanarkhede
committed

Commits on Jan 13, 2015

Commits on Jan 14, 2015

KAFKA-1723 (delta patch to fix javadoc); make the metrics name in new producer more standard; patched by Manikumar Reddy; reviewed by Jun Rao

omkreddy
authored and
junrao
committed

Commits on Jan 15, 2015

Commits on Jan 16, 2015

kafka-1868; ConsoleConsumer shouldn't override dual.commit.enabled to false if not explicitly set; patched by Jun Rao; reviewed by Jeol Koshy
junrao
committed

Commits on Jan 17, 2015

Commits on Jan 19, 2015

Commits on Jan 20, 2015

KAFKA-1823; Fix transient failure in PartitionAssignorTest; reviewed by Guozhang Wang and Neha Narkhede
jjkoshy
committed

Commits on Jan 22, 2015

KAFKA-1848; check consumer shutting down flag inside retry loop; reviewed by Guozhang Wang

auradkar
authored and
Guozhang Wang
committed

Commits on Jan 23, 2015

Commits on Jan 24, 2015

KAFKA-1896; Record size function should check if value is null; reviewed by Guozhang Wang

becketqin
authored and
Guozhang Wang
committed

Commits on Jan 29, 2015

Commits on Jan 30, 2015

KAFKA-1760 Follow-up: fix compilation issue with Scala 2.11
jkreps
committed

Commits on Feb 3, 2015

Commits on Feb 9, 2015

Commits on Feb 10, 2015

KAFKA-1476 Added a ConsumerCommand tool that will replace other consumer related tools in the future; reviewed by Neha Narkhede

onurkaraman
authored and
nehanarkhede
committed

Commits on Feb 13, 2015

Commits on Feb 18, 2015

Commits on Feb 19, 2015

Commits on Feb 20, 2015

Minor typo in KafkaConfig; reviewed by Gwen Shapira

zhouyaguo
authored and
nehanarkhede
committed

Commits on Feb 21, 2015

KAFKA-1867 liveBroker list not updated on a cluster with no topics; reviewed by Neha Narkhede

Sriharsha Chintalapani
authored and
nehanarkhede
committed
Leaner DelayedItem; reviewed by Neha Narkhede and Joel Koshy

ymatsuda
authored and
nehanarkhede
committed
KAFKA-1919: Always update the metadata, when a metadata response is received to ensure we back off.
jkreps
committed

Commits on Feb 22, 2015

KAFKA-1947 can't explicitly set replica-assignment when add partitions; reviewed by Neha Narkhede

Honghai Chen
authored and
nehanarkhede
committed
KAFKA-1757 Unmap file prior to delete on windows.
jkreps
committed

Commits on Feb 23, 2015

kafka-1971; starting a broker with a conflicting id will delete the previous broker registration; patched by Jun Rao; reviewed by Neha Narkhede
junrao
committed

Commits on Feb 24, 2015

Commits on Feb 25, 2015

KAFKA-1953; KAFKA-1962; Disambiguate purgatory metrics; restore delayed request metrics; reviewed by Guozhang Wang
jjkoshy
committed

Commits on Feb 26, 2015

kafka-1881; transient unit test failure in testDeleteTopicWithCleaner due to OOME; patched by Ewen Cheslack-Postava; reviewed by Jun Rao

ewencp
authored and
junrao
committed

Commits on Feb 27, 2015

Commits on Feb 28, 2015

KAFKA-1866 LogStartOffset gauge throws exceptions after log.delete(); reviewed by Neha Narkhede

Sriharsha Chintalapani
authored and
nehanarkhede
committed
KAFKA-1824 ConsoleProducer - properties key.separator and parse.key no longer work; reviewed by Neha Narkhede

gwenshap
authored and
nehanarkhede
committed
KAFKA-1865 Add a flush() method to the producer.
jkreps
committed

Commits on Mar 3, 2015

Commits on Mar 5, 2015

KAFKA-1845 KafkaConfig should use ConfigDef patch by Andrii Biletskyi reviewed by Gwen Shapira
joestein
committed

Commits on Mar 8, 2015

KAFKA-2009 Fix two minor bugs in mirror maker.

becketqin
authored and
jkreps
committed

Commits on Mar 10, 2015

Commits on Mar 11, 2015

Commits on Mar 12, 2015

kafka-1461; Replica fetcher thread does not implement any back-off behavior; patched by Sriharsha Chintalapani; reviewed by Jun Rao

Sriharsha Chintalapani
authored and
junrao
committed

Commits on Mar 13, 2015

Commits on Mar 17, 2015

KAFKA-1997; Follow-up to add the shutdown hook before starting the consumers; reviewed by Guozhang Wang

becketqin
authored and
guozhangwang
committed

Commits on Mar 18, 2015

KAFKA-1997; Hopefully last follow-up fix to get messageHandlerArgs right

becketqin
authored and
guozhangwang
committed

Commits on Mar 19, 2015

Commits on Mar 24, 2015

KAFKA-2042; Update topic list of the metadata regardless of cluster information; reviewed by Guozhang Wang

becketqin
authored and
guozhangwang
committed

Commits on Mar 26, 2015

KAFKA-527; Use in-place decompression enabled inner iterator to replace old decompress function; reviewed by Joel Koshy and Jun Rao
guozhangwang
committed

Commits on Mar 27, 2015

KAFKA-1634; Bump up Offset Commit Request to v2 to add global retention and remove per-partition commit timestamp; reviewed by Joel Koshy and Jun Rao
guozhangwang
committed

Commits on Mar 28, 2015

kafka-2044; Support requests and responses from o.a.k.common in KafkaApis; patched by Gwen Shapira; reviewed by Jun Rao

gwenshap
authored and
junrao
committed

Commits on Apr 1, 2015

Commits on Apr 3, 2015

kafka-2016; RollingBounceTest takes long; patched by Ted Malaska; reviewed by Jun Rao

Ted Malaska
authored and
junrao
committed
KAFKA-1961 Prevent deletion of _consumer_offsets topic; reviewed by Neha Narkhede, Gwen Shapira and Jun Rao

Ted Malaska
authored and
nehanarkhede
committed

Commits on Apr 4, 2015

Commits on Apr 5, 2015

KAFKA-1005 Shutdown consumer at the end of consumer performance test.

pmackles
authored and
jkreps
committed

Commits on Apr 6, 2015

Commits on Apr 7, 2015

Commits on Apr 8, 2015

Commits on Apr 9, 2015

kafka-2096; Enable keepalive socket option for broker to prevent socket leak; patched by Allen Wang; reviewed by Jun Rao

Allen Wang
authored and
junrao
committed
kafka-2090; Remove duplicate check to metadataFetchInProgress; patched by Tim Brook; reviewed by Ewen Cheslack-PostavaJun Rao

Tim-Brooks
authored and
junrao
committed
kafka-2112; make overflowWheel volatile; patched by Yasuhiro Matsuda; reviewed by Jun Rao

ymatsuda
authored and
junrao
committed

Commits on Apr 10, 2015

trivial fix for compilation error in scala 2.9.1

ewencp
authored and
junrao
committed

Commits on Apr 13, 2015

kafka-2115; Error updating metrics in RequestChannel; patched by Gwen Shapira; reviewed by Jun Rao

gwenshap
authored and
junrao
committed

Commits on Apr 14, 2015

Commits on Apr 15, 2015

KAFKA-2056; Fix transient testRangePartitionAssignor failure; reviewed by Guozhang Wang

lvfangmin
authored and
guozhangwang
committed

Commits on Apr 16, 2015

kafka-2113; TestPurgatoryPerformance does not compile using IBM JDK; patched by Rajini Sivaram; reviewed by Yasuhiro Matsuda and Jun Rao

rajinisivaram
authored and
junrao
committed

Commits on Apr 18, 2015

Commits on Apr 19, 2015

Commits on Apr 20, 2015

Commits on Apr 22, 2015

KAFKA-2121; Close internnal modules upon client shutdown; reviewed by Ewen Cheslack-Postava and Guozhang Wang

stevenzwu
authored and
guozhangwang
committed

Commits on Apr 24, 2015

KAFKA-2138; Fix producer to honor retry backoff; reviewed by Joel Koshy and Guozhang Wang

becketqin
authored and
jjkoshy
committed

Commits on Apr 25, 2015

KAFKA-2034 sourceCompatibility not set in Kafka build.gradle; reviewed by Neha Narkhede and Ewen Cheslack-Postava
nehanarkhede
committed

Commits on Apr 26, 2015

KAFKA-2140 Improve code readability; reviewed by Neha Narkhede

ijuma
authored and
Neha Narkhede
committed
KAFKA-2122 Remove controller.message.queue.size Config; reviewed by Neha Narkhede, Jun Rao, Onur

Sriharsha Chintalapani
authored and
Neha Narkhede
committed
KAFKA-2140 follow up, checking in newly renamed file ConsumerRebalanceFailedException

ijuma
authored and
Neha Narkhede
committed
KAFKA-2128 kafka.Kafka should return non-zero exit code when caught exception; reviewed by Neha

sasakitoa
authored and
Neha Narkhede
committed
KAFKA-2114 Unable to change min.insync.replicas default; reviewed by Neha

gwenshap
authored and
Neha Narkhede
committed

Commits on Apr 27, 2015

kafka-2118; Cleaner cannot clean after shutdown during replaceSegments; patched by Rajini Sivaram; reviewed by Jun Rao

rajinisivaram
authored and
junrao
committed

Commits on Apr 28, 2015

KAFKA-2121 Follow-up: minor bug fix as pointed out by Sean Lydon
guozhangwang
committed
kafka-1940; Initial checkout and build failing; patched by Martin Lemanski; reviewed by Jun Rao

Martin Lemanski
authored and
junrao
committed
KAFKA-1054; Eliminate Scala Compilation Warnings

Jon Riehl
authored and
Neha Narkhede
committed
KAFKA-1621 : Standardize --messages option. Closes #58

rekhajoshm
authored and
Neha Narkhede
committed

Commits on May 4, 2015

KAFKA-2068 Phase 1; Merge in KAFKA-1841; reviewed by Jun Rao
guozhangwang
committed
KAFKA-1886 SimpleConsumer swallowing ClosedByInterruptException; reviewed by Neha Narkhede

auradkar
authored and
Neha Narkhede
committed
KAFKA-2153 kafka-patch-review tool uploads a patch even if it is empty; reviewed by Neha Narkhede, Gwen Shapira

Ashish Singh
authored and
Neha Narkhede
committed

Commits on May 7, 2015

KAFKA-1884; Add logging upon metadata response errors; reviewed by Guozhang Wang

omkreddy
authored and
guozhangwang
committed

Commits on May 8, 2015

Commits on May 12, 2015

KAFKA-2150; move partitionMapCond.await into partitionMapLock; reviewed by Guozhang Wang

Sriharsha Chintalapani
authored and
guozhangwang
committed
KAFKA-2175; Change INFO to DEBUG for socket close on no error; and partition reassignment JSON; reviewed by Gwen Shapira and Joel Koshy

Todd Palino
authored and
jjkoshy
committed
KAFKA-2163; The offsets manager's stale-offset-cleanup and offset load should be mutually exclusive; reviewed by Jun Rao
jjkoshy
committed
KAFKA-1660; Add API to the producer to support close with a timeout; reviewed by Joel Koshy and Jay Kreps.

becketqin
authored and
jjkoshy
committed

Commits on May 14, 2015

KAFKA-1334; Add the heartbeat logic to consumer coordinator; reviewed by Guozhang Wang

onurkaraman
authored and
guozhangwang
committed

Commits on May 18, 2015

kafka-2169; Upgrade to zkclient-0.5; patched by Parth Brahmbhatt; reviewed by Jun Rao

Parth Brahmbhatt
authored and
junrao
committed

Commits on May 20, 2015

Commits on May 21, 2015

Commits on May 24, 2015

KAFKA-1737; Enforce ZKSerializer while creating ZkClient; reviewed by Guozhang Wang

vivekpm
authored and
guozhangwang
committed

Commits on May 28, 2015

kafka-2189; Snappy compression of message batches less efficient in 0.8.2.1; patched by Ismael Juma; reviewed by Jun Rao

ijuma
authored and
junrao
committed
KAFKA-2186; Follow-up to KAFKA-1650 - add selective offset commit to consumer connector API; reviewed by Joel Koshy

becketqin
authored and
jjkoshy
committed
KAFKA-2091; Expose a partitioner interface in the new producer

Sriharsha Chintalapani
authored and
jjkoshy
committed

Commits on May 29, 2015

kafka-2185; Update to Gradle 2.4; patched by Ismael Juma; reviewed by Jun Rao

ijuma
authored and
junrao
committed
KAFKA-2199 Make signing artifacts optional and disabled by

ewencp
authored and
jkreps
committed

Commits on Jun 1, 2015

kafka-2226; NullPointerException in TestPurgatoryPerformance; patched by Yasuhiro Matsuda; reviewed by Onur Karaman, Guozhang Wang and Jun Rao

ymatsuda
authored and
junrao
committed

Commits on Jun 3, 2015

Commits on Jun 4, 2015

kafka-1928; Move kafka.network over to using the network classes in org.apache.kafka.common.network; patched by Gwen Shapira; reviewed by Joel Koshy, Jay Kreps, Jiangjie Qin, Guozhang Wang and Jun Rao

gwenshap
authored and
junrao
committed

Commits on Jun 5, 2015

KAFKA-2246; UnknownTopicOrPartitionException should be an instance of InvalidMetadataException; reviewed by Ewen Cheslack-Postava and Joel Koshy

becketqin
authored and
jjkoshy
committed

Commits on Jun 10, 2015

KAFKA-2253; fix deadlock between removeWatchersLock and watcher operations list lock; reviewed by Onur Karaman and Jiangjie Qin
guozhangwang
committed

Commits on Jun 11, 2015

kafka-2005; Generate html report for system tests; patched by Ashish Singh; reviewed by Jun Rao

Ashish Singh
authored and
junrao
committed

Commits on Jun 12, 2015

kafka-2266; Client Selector can drop idle connections without notifying NetworkClient; patched by Jason Gustafson; reviewed by Jun Rao

Jason Gustafson
authored and
junrao
committed
kafka-2232; make MockProducer generic; patched by Alexander Pakulov; reviewed by Jun Rao

apakulov
authored and
junrao
committed

Commits on Jun 13, 2015

kafka-2164; ReplicaFetcherThread: suspicious log message on reset offset; patched by Alexey Ozeritski; reviewed by Jun Rao

resetius
authored and
junrao
committed

Commits on Jun 16, 2015

Commits on Jun 18, 2015

Commits on Jun 19, 2015

Commits on Jun 22, 2015

kafka-2290; OffsetIndex should open RandomAccessFile consistently; patched by Chris Black; reviewed by Jun Rao

Chris Black
authored and
junrao
committed
kafka-2235; LogCleaner offset map overflow; patched by Ivan Simoneko; reviewed by Jun Rao

isimonenko
authored and
junrao
committed
KAFKA-2245; Add response tests for consumer coordinator; reviewed by Joel Koshy

onurkaraman
authored and
jjkoshy
committed
KAFKA-2293; Fix incorrect format specification in Partition.scala; reviewed by Joel Koshy

auradkar
authored and
jjkoshy
committed

Commits on Jun 23, 2015

Commits on Jun 30, 2015

KAFKA-2281: avoid unnecessary value copying if logAsString is false; reviewed by Guozhang Wang

xiaotao183
authored and
guozhangwang
committed

Commits on Jul 1, 2015

KAFKA-2168: minor follow-up patch; reviewed by Guozhang Wang

hachikuji
authored and
guozhangwang
committed

Commits on Jul 2, 2015

KAFKA-1740: merge offset manager into consumer coordinator; reviewed by Onur Karaman and Jason Gustafson
guozhangwang
committed

Commits on Jul 6, 2015

Commits on Jul 7, 2015

KAFKA-2314: proper MirrorMaker's message handler help message; reviewed by Guozhang Wang

lazyval
authored and
guozhangwang
committed
kafka-1367; Broker topic metadata not kept in sync with ZooKeeper; patched by Ashish Singh; reviewed by Jun Rao

Ashish Singh
authored and
junrao
committed
KAFKA-2304 Supported enabling JMX in Kafka Vagrantfile patch by Stevo Slavic reviewed by Ewen Cheslack-Postava
joestein
committed
KAFKA-2306: add another metric for buffer exhausted; reviewed by Guozhang Wang

lindong28
authored and
guozhangwang
committed
KAFKA-2317: follow-up of KAFKA1367; reviewed by Guozhang Wang

Ashish Singh
authored and
guozhangwang
committed
KAFKA-2313: javadoc fix for KafkaConsumer deserialization; reviewed by Guozhang Wang

onurkaraman
authored and
guozhangwang
committed

Commits on Jul 8, 2015

KAFKA-2298; Client Selector can drop connections on InvalidReceiveException without notifying NetworkClient; reviewed by Jason Gustafson and Joel Koshy

lindong28
authored and
jjkoshy
committed
Trivial commit - explicitly exclude build/rat-report.xml from rat check
jjkoshy
committed
KAFKA-2308: make MemoryRecords idempotent; reviewed by Guozhang Wang

gwenshap
authored and
guozhangwang
committed
KAFKA-2316: Drop java 1.6 support; patched by Sriharsha Chintalapani reviewed by Ismael Juma and Gwen Shapira

Sriharsha Chintalapani
authored and
gwenshap
committed

Commits on Jul 9, 2015

KAFKA-2327; broker doesn't start if config defines advertised.host but not advertised.port

Geoff Anderson
authored and
gwenshap
committed

Commits on Jul 10, 2015

Commits on Jul 13, 2015

KAFKA-2312: use atomic long for thread id reference; reviewed by Ewen Cheslack-Postava, Jason Gustafson, Ismael Juma and Guozhang Wang

Tim-Brooks
authored and
guozhangwang
committed

Commits on Jul 14, 2015

kafka-972; MetadataRequest returns stale list of brokers; patched by Ashish Singh; reviewed by Jun Rao

Ashish Singh
authored and
junrao
committed
KAFKA-2198: kafka-topics.sh exits with 0 status on failures; patched by Manikumar Reddy reviewed by Gwen Shapira

omkreddy
authored and
gwenshap
committed

Commits on Jul 15, 2015

Commits on Jul 16, 2015

[MINOR] fix new consumer heartbeat reschedule bug

hachikuji
authored and
guozhangwang
committed
KAFKA-2032: validate consumer's partition-assignment config; reviewed by Jason Rosenberg, Sriharsha Chintalapani and Guozhang Wang

Parth Brahmbhatt
authored and
guozhangwang
committed
kafka-2323; Simplify ScalaTest dependency versions; patched by Ismael Juma; reviewed by Jun Rao

ijuma
authored and
junrao
committed
kafka-2241; AbstractFetcherThread.shutdown() should not block on ReadableByteChannel.read(buffer); patched by Dong Lin; reviewed by Jun Rao

lindong28
authored and
junrao
committed

Commits on Jul 17, 2015

kafka-2174; Wrong TopicMetadata deserialization; patched by Alexey Ozeritskiy; reviewed by Jun Rao

resetius
authored and
junrao
committed
kafka-2271; transient unit test failure in KafkaConfigConfigDefTest.testFromPropsToProps; patched by Jason Gustafson; reviewed by Jun Rao

Jason Gustafson
authored and
junrao
committed
kafka-2103; kafka.producer.AsyncProducerTest failure; patched by Ewen Cheslack-Postava; reviewed by Jun Rao

ewencp
authored and
junrao
committed
KAFKA-2324; Update to Scala 2.11.7

ijuma
authored and
gwenshap
committed
KAFKA-2345; Attempt to delete a topic already marked for deletion throws ZkNodeExistsException; patched by Ashish Singh; reviewed by Sriharsha Chintalapani and Ismael Juma

Ashish Singh
authored and
gwenshap
committed
Adding a file missed while committing KAFKA-2345
gwenshap
committed