root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity
1,228 Commits 84 Branches 278 Tags 628 MiB
Commit Graph

1228 Commits

Author SHA1 Message Date
Geoff Anderson a278988580 fixed typos 2015-05-26 15:21:23 -07:00
Rajini Sivaram 5397d3c53e kafka-2113; TestPurgatoryPerformance does not compile using IBM JDK; patched by Rajini Sivaram; reviewed by Yasuhiro Matsuda and Jun Rao 2015-04-16 10:26:49 -07:00
Fangmin Lv bfbd3acbf7 KAFKA-2056; Fix transient testRangePartitionAssignor failure; reviewed by Guozhang Wang 2015-04-15 11:16:58 -07:00
Flutra Osmani 9e5d481c7c KAFKA-1416; Unify sendMessages in TestUtils; reviewed by Guozhang Wang 2015-04-14 14:42:53 -07:00
Guozhang Wang 157fba8407 KAFKA-2117; Use the correct metadata field for reading offset struct; reviewed by Jun Rao and Jiangjie Qin 2015-04-13 18:41:33 -07:00
Gwen Shapira aa365639b2 kafka-2115; Error updating metrics in RequestChannel; patched by Gwen Shapira; reviewed by Jun Rao 2015-04-13 09:21:53 -05:00
Ewen Cheslack-Postava fb86cf6338 trivial fix for compilation error in scala 2.9.1 2015-04-10 08:09:53 -07:00
Yasuhiro Matsuda 26673f982e kafka-2112; make overflowWheel volatile; patched by Yasuhiro Matsuda; reviewed by Jun Rao 2015-04-09 12:15:25 -07:00
Tim Brooks 2490b1c499 kafka-2090; Remove duplicate check to metadataFetchInProgress; patched by Tim Brook; reviewed by Ewen Cheslack-PostavaJun Rao 2015-04-08 19:06:05 -07:00
Allen Wang 194d1fc030 kafka-2096; Enable keepalive socket option for broker to prevent socket leak; patched by Allen Wang; reviewed by Jun Rao 2015-04-08 17:21:29 -07:00
Yasuhiro Matsuda 6880f66c97 kafka-1989; New purgatory design; patched by Yasuhiro Matsuda; reviewed by Guozhang Wang and Jun Rao 2015-04-08 15:19:59 -07:00
Dave Beech d3aa99c54a kafka-2109; Support retries in KafkaLog4jAppender; patched by Dave Beech; reviewed by Jun Rao 2015-04-08 14:33:47 -07:00
Gwen Shapira b47f811ee1 kafka-2104; testDuplicateListeners() has a typo; patched by Gwen Shapira; reviewed by Sriharsha Chintalapani, Onur Karaman and Jun Rao 2015-04-08 13:28:37 -07:00
Daniel Compton fef709d51a kafka-1517; Messages is a required argument to Producer Performance Test; patched by Daniel Compton; reviewed by Jun Rao 2015-04-07 22:18:56 -07:00
Grant Henke 06a26656ff kafka-1973; Remove the accidentally created LogCleanerManager.scala.orig; patched by Grant Henke; reviewed by Jun Rao 2015-04-07 21:18:00 -07:00
Guozhang Wang 013cda2d79 KAFKA-1910 Follow-up; Revert the no-offset-committed error code; reviewed by Joel Koshy 2015-04-07 15:38:36 -07:00
Sriharsha Chintalapani 79f7cca85e KAFKA-1461; Implement per-partition back-off for replica fetcher; reviewed by Jun Rao and Guozhang Wang 2015-04-07 15:26:26 -07:00
Gwen Shapira d9ab917dcc kafka-1992; checkEnoughReplicasReachOffset doesn't need to get requiredAcks; patched by Gwen Shapira; reviewed by Jeff Holoman, Jiangjie Qin and Jun Rao 2015-04-07 15:10:47 -07:00
Pierre-Yves Ritschard b1cc725107 kafka-2033; Small typo in documentation; patched by Pierre-Yves Ritschard; reviewed by Jun Rao 2015-04-07 14:40:06 -07:00
Gwen Shapira 04fce48e1a kafka-2099; BrokerEndPoint file, methods and object names should match; patched by Gwen Shapira; reviewed by Sriharsha Chintalapani and Jun Rao 2015-04-06 18:20:45 -07:00
Grant Henke 75e1cc8bc4 kafka-2043; CompressionType is passed in each RecordAccumulator append; patched by Grant Henke; reviewed by Jun Rao 2015-04-06 13:34:31 -07:00
Tong Li 9c23d93553 kafka-1926; Replace kafka.utils.Utils with o.a.k.common.utils.Utils; patched by Tong Li; reviewed by Jun Rao 2015-04-05 21:46:11 -07:00
Gwen Shapira 53f31432a0 kafka-1809; Refactor brokers to allow listening on multiple ports and IPs; patched by Gwen Shapira; reviewed by Joel Koshy and Jun Rao 2015-04-05 17:21:37 -07:00
paul mackles 07598ad8a4 KAFKA-1005 Shutdown consumer at the end of consumer performance test. 2015-04-04 19:36:54 -07:00
Yaguo Zhou 9a071017ee KAFKA-1996 Fix scaladoc error. 2015-04-04 16:05:45 -07:00
Rajini Sivaram 7acfa92c09 KAFKA-2024 Log compaction can generate unindexable segments. 2015-04-04 15:56:17 -07:00
Yaguo Zhou a686a67f60 KAFKA-2002: Mx4JLoader doesn't disable when kafka_mx4jenable=false. 2015-04-04 15:27:41 -07:00
Tim Brooks 70e5c92e21 KAFKA-2050 Avoid calling .size() on linked list. 2015-04-04 15:17:09 -07:00
Ewen Cheslack-Postava 6adaffd8ea KAFKA-1501 Let the OS choose the port in unit tests to avoid collisions. Patch by Ewen CP, reviewed by Guozhang and me. 2015-04-04 14:26:38 -07:00
Aditya Auradkar 15b93a410a KAFKA-1546; Automate replica lag tuning; reviewed by Joel Koshy, Neha 
Narkhede, Jun Rao and Guozhang Wang
 2015-04-03 18:40:17 -07:00
Ted Malaska 48f9970472 KAFKA-1961 Prevent deletion of _consumer_offsets topic; reviewed by Neha Narkhede, Gwen Shapira and Jun Rao 2015-04-03 11:43:59 -07:00
Ted Malaska ad722531da kafka-2016; RollingBounceTest takes long; patched by Ted Malaska; reviewed by Jun Rao 2015-04-02 18:20:54 -07:00
Yasuhiro Matsuda 619d78eb52 kafka-2013; benchmark test for the purgatory; patched by Yasuhiro Matsuda; reviewed by Jun Rao 2015-04-01 16:14:48 -07:00
Ismael Juma 66c6f9b1c4 kafka-2039; Update Scala to 2.10.5 and 2.11.6; patched by Ismael Juma; reviewed by Jun Rao 2015-04-01 13:26:45 -07:00
Gwen Shapira d8fe98efee kafka-2044; Support requests and responses from o.a.k.common in KafkaApis; patched by Gwen Shapira; reviewed by Jun Rao 2015-03-28 08:39:48 -07:00
Guozhang Wang c5df2a8e3a 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 2015-03-26 17:16:33 -07:00
Guozhang Wang d2f50fc388 KAFKA-527; Use in-place decompression enabled inner iterator to replace old decompress function; reviewed by Joel Koshy and Jun Rao 2015-03-26 15:43:18 -07:00
Jiangjie Qin 5b42b538eb KAFKA-2047; Move the stream creation into concurrent mirror maker threads; reviewed by Guozhang Wang 2015-03-25 14:01:19 -07:00
Yasuhiro Matsuda a74688de46 kafka-527; Compression support does numerous byte copies; patched by Yasuhiro Matsuda; reviewed by Guozhang Wang and Jun Rao 2015-03-25 13:08:38 -07:00
Joe Stein eb2100876b KAFKA-1856 Add PreCommit Patch Testing patch by Ashish K Singh reviewed by Gwen Shapira 2015-03-25 01:57:42 -04:00
Tao Xiao 4e0da4965b KAFKA-2048; Change lock synchronized to inLock() for partitionMapCond; reviewed by Guozhang Wang 2015-03-24 20:56:22 -07:00
Jiangjie Qin 991195416e KAFKA-2042; Update topic list of the metadata regardless of cluster information; reviewed by Guozhang Wang 2015-03-24 15:48:46 -07:00
Guozhang Wang c62cff3559 trivial fix on coding style 2015-03-19 16:10:23 -07:00
Guozhang Wang b2c833aa41 KAFKA-1910; Fix two bugs on MemoryRecords and KafkaConsumer; reviewed by Onur Karaman 2015-03-19 15:52:54 -07:00
Jiangjie Qin 82789e7519 KAFKA-1997; Hopefully last follow-up fix to get messageHandlerArgs right 2015-03-18 14:58:11 -07:00
Jiangjie Qin 5bbbb7fddb KAFKA-1997; Follow-up to add the shutdown hook before starting the consumers; reviewed by Guozhang Wang 2015-03-17 14:22:01 -07:00
Guozhang Wang 1caaf6db40 KAFKA-1863; Add docs for possible thrown exception in Callback; reviewed by Jiangjie Qin 2015-03-13 15:17:08 -07:00
Jiangjie Qin c41c7b40b6 KAFKA-1997; Refactor MirrorMaker based on KIP-3; reviewed by Joel Koshy and Guozhang Wang 2015-03-13 15:07:48 -07:00
Sriharsha Chintalapani b7439c8081 kafka-1461; Replica fetcher thread does not implement any back-off behavior; patched by Sriharsha Chintalapani; reviewed by Jun Rao 2015-03-12 13:56:52 -07:00
Guozhang Wang 01f20e029f KAFKA-1910 Follow-up again; fix ListOffsetResponse handling for the expected error codes 2015-03-11 16:25:21 -07:00