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

16580 Commits

Author SHA1 Message Date
Joel Koshy 517af4779a KAFKA-916; Break deadlock between fetcher shutdown and error partition handling; reviewed by Jun Rao. 2013-05-28 09:55:39 -07:00
Phil Hargett 59599cc127 kafka-919; Disabling of auto commit is ignored during consumer group rebalancing; patched by Phil Hargett; reviewed by Jun Rao 2013-05-24 22:00:57 -07:00
Joel Koshy ffd84eb23f KAFKA-914; Break deadlock between initial rebalance and watcher-triggered rebalances; reviewed by Jun Rao and Neha Narkhede 2013-05-22 16:26:04 -07:00
Jun Rao 32cd8994bf kafka-907; controller needs to close socket channel to brokers on exception ; patched by Jun Rao; reviewed by Neha Narkhede 2013-05-22 16:23:21 -07:00
Neha Narkhede e93937c886 Minor logging fix 2013-05-22 10:29:45 -07:00
Neha Narkhede 2d40ca30d3 KAFKA-901 follow up changes to fix update metadata response handling and request logging 2013-05-21 10:01:51 -07:00
Neha Narkhede eff59330f2 KAFKA-901: Follow up minor changes 2013-05-17 16:59:40 -07:00
Neha Narkhede cfdc403e17 KAFKA-901 Kafka server can become unavailable if clients send several metadata requests; reviewed by Jun Rao 2013-05-17 15:45:33 -07:00
Neha Narkhede 988d4d8e65 KAFKA-892 Change request log to include request completion not handling; reviewed by Joel Koshy 2013-04-30 17:20:54 -07:00
Neha Narkhede cae19aa44f KAFKA-889 Add mbeans to track socket server's response queue size in addition to request queue size; reviewed by Jun Rao and Joel Koshy 2013-04-30 15:35:01 -07:00
Neha Narkhede d726e14eea KAFKA-890 The list of brokers for fetching metadata should be shuffled; reviewed by Joel Koshy 2013-04-30 12:42:15 -07:00
Neha Narkhede 103aef8ca3 KAFKA-887 Standardize logging for partition information to [%s,%d] format; reviewed by Swapnil and Jun 2013-04-29 17:04:42 -07:00
Neha Narkhede a61e738138 change to standardize on [%s,%d] for partition 2013-04-29 11:09:19 -07:00
Joel Koshy e37a464420 Trivial commit - warn on consumer fetch request errors. 2013-04-26 14:13:00 -07:00
Jun Rao 6e640e3556 kafka-880; NoLeaderPartitionSet should be cleared before leader finder thread is started up; patched by Jun Rao; reviewed by Neha Narkhede 2013-04-25 19:03:21 -07:00
Swapnil Ghike 2d7403174f kafka-871; Rename ZkConfig properties; patched by Swapnil Ghike; reviewed by Jun Rao 2013-04-25 18:57:31 -07:00
Joel Koshy ede85875a3 KAFKA-872; Socket server should set send/recv socket buffer sizes; reviewed by Jun Rao. 2013-04-23 10:40:47 -07:00
David Stein 1976ce8069 KAFKA-870 hadoop-producer KafkaRecordWriter writes entire input buffer capacity, even when intended payload is smaller; reviewed by Neha Narkhede 2013-04-22 19:20:01 -07:00
Sriram Subramanian f1d2141ca0 kafka-866; Recover segment does shallow iteration to fix index causing inconsistencies; patched by Sriram Subramanian; reviewed by Jun Rao 2013-04-22 16:50:29 -07:00
Jun Rao 731ba9007d kafka-823; merge 0.8 (51421fcc01) to trunk; patched by Jun Rao; reviewed by Jay Kreps 2013-04-17 21:52:04 -07:00
Cosmin Lehene c5bb1d4994 kafka-843; (addendum) Re-add the release-zip sbt target; patched by Cosmin Lehene; reviewed by Jun Rao 2013-04-17 08:20:30 -07:00
Sriram Subramanian b29b6296ac kafka-861; IndexOutOfBoundsException while fetching data from leader; patched by Sriram Subramanian; reviewed by Jun Rao and Neha Narkhede 2013-04-15 18:09:57 -07:00
Cosmin Lehene 158baf661c kafka-843; Re-add the release-zip sbt target; patched by Cosmin Lehene; reviewed by Jun Rao 2013-04-11 11:01:11 -07:00
Neha Narkhede f9e36ca790 KAFKA-860 Replica fetcher thread errors out and dies during rolling bounce of cluster; reviewed by Jun Rao, Jay Kreps 2013-04-11 10:09:24 -07:00
Neha Narkhede 6dbf9212ae KAFKA-826 Make Kafka 0.8 depend on metrics 2.2.0 instead of 3.x; reviewed by Swapnil Ghike, Neha Narkhede, Matt Christiansen, Scott Carey 2013-04-09 16:07:58 -07:00
Jun Rao ae362b0864 kafka-649; Cleanup log4j logging; patched by Jun Rao; reviewed by Jay Kreps 2013-04-09 15:37:33 -07:00
Neha Narkhede ef123c20b8 KAFKA-858 High watermark values can be overwritten during controlled shutdown; reviewed by Jun Rao 2013-04-09 14:11:07 -07:00
Jun Rao d4a70eb9b0 kafka-850; add an option to show under replicated partitions in list topic command; patched by Jun Rao; reviewed by Neha Narkhede 2013-04-08 09:48:03 -07:00
Neha Narkhede 756be5363b KAFKA-849 Bug in controller's startup/failover logic fails to update in memory leader and isr cache causing other state changes to work incorrectly; reviewed by Jun Rao and Swapnil Ghike 2013-04-04 21:27:20 -07:00
Neha Narkhede 1d3c343f57 KAFKA-851 Broken handling of leader and isr request leads to incorrect high watermark checkpoint file; reviewed by Jun Rao and Swapnil Ghike 2013-04-04 21:19:52 -07:00
John Fung afecc9f231 KAFKA-844 System Test - Mirror Maker cases enhancements; reviewed by Neha Narkhede 2013-04-04 16:19:00 -07:00
Neha Narkhede 3ead78b966 KAFKA-840 Post commit 2013-04-03 23:40:05 -07:00
Jun Rao 5a50f7e555 kafka-846; AbstractFetcherThread should do shallow instead of deep iteration; patched by Jun Rao; reviewed by Neha Narkhede 2013-04-03 17:15:06 -07:00
Neha Narkhede bd262ac708 KAFKA-842 Mirror maker can lose some messages during shutdown; reviewed by Jun Rao 2013-04-03 13:43:50 -07:00
Jun Rao 3c27988ca4 kafka-827; improve list topic output format; patched by Jun Rao; reviewed by Neha Narkhede 2013-04-01 10:41:40 -07:00
Swapnil Ghike a9ce73cfd3 KAFKA-840 Controller tries to perform preferred replica election on failover before state machines have started up; reviewed by Neha Narkhede 2013-04-01 09:17:20 -07:00
Jun Rao 06911384f2 trivial fix to print key properly in DumpLogSegments 2013-03-29 13:24:45 -07:00
Dragos Manolescu 68528dafa1 kafka-807; LineMessageReader doesn't correctly parse the key separator; patched by Dragos Manolescu; reviewed by Jun Rao 2013-03-29 08:31:50 -07:00
Neha Narkhede 9f6af315ca KAFKA-831 Controller does not send the complete list of partitions to a newly started broker; reviewed by Jun Rao and Swapnil Ghike 2013-03-29 08:26:41 -07:00
Jun Rao 6e05d7da86 kafka-832; 0.8 Consumer prevents rebalance if consumer thread is blocked or slow; patched by Jun Rao; reviewed by Neha Narkhede 2013-03-28 16:34:47 -07:00
Neha Narkhede 1d5e95f6c4 KAFKA-831 Controller does not send the complete list of partitions to a newly started broker; reviewed by Jun Rao 2013-03-28 16:29:37 -07:00
Neha Narkhede 66b1038957 KAFKA-829 Mirror maker needs to share the migration tool request channel; reviewed by Jun Rao 2013-03-28 09:54:02 -07:00
Neha Narkhede be3ce14721 Missing file from KAFKA-828 2013-03-28 09:45:52 -07:00
Swapnil Ghike 2fe3f9fef6 KAFKA-828 Preferred Replica Election does not delete the admin path on controller failover; reviewed by Neha Narkhede and Jun Rao 2013-03-28 08:51:00 -07:00
John Fung f570cce1f4 kafka-819; System Test : Add validation of log segment index to offset; patched by John Fung; reviewed by Jun Rao 2013-03-27 16:58:54 -07:00
Neha Narkhede c5e354d3ab KAFKA-830 partition replica assignment map in the controller should be a Set; reviewed by Jun Rao and Swapnil Ghike 2013-03-27 13:29:18 -07:00
John Fung 26c50fac47 kafka-791; Fix validation bugs in System Test; patched by John Fung; reviewed by Jun Rao 2013-03-25 14:08:24 -07:00
Jun Rao e367f3ffb3 kafka-825; KafkaController.isActive() needs to be synchronized; patched by Jun Rao; reviewed by Neha Narkhede 2013-03-25 10:47:29 -07:00
Swapnil Ghike df221297c7 kafka-813; (add the missing file) Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao 2013-03-25 10:45:44 -07:00
Swapnil Ghike 28ee785536 kafka-813; Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao 2013-03-25 09:31:57 -07:00