| jkr...@apache.org |
svn commit: r1498605 - in /kafka/site: 08/quickstart.html 08/tools.html committers.html contact.html design.html downloads.html faq.html includes/header.html introduction.html styles.css uses.html |
Mon, 01 Jul, 17:44 |
| jkr...@apache.org |
svn commit: r1498621 - in /kafka/site: diagrams/consumer-groups.graffle images/consumer-groups.png introduction.html styles.css |
Mon, 01 Jul, 18:57 |
| jkr...@apache.org |
svn commit: r1498724 - /kafka/site/uses.html |
Mon, 01 Jul, 22:20 |
| jkr...@apache.org |
svn commit: r1498744 - in /kafka/site: 08/configuration.html committers.html design.html implementation.html includes/header.html |
Tue, 02 Jul, 00:07 |
| jkr...@apache.org |
svn commit: r1499548 - /kafka/site/introduction.html |
Wed, 03 Jul, 20:37 |
| jun...@apache.org |
svn commit: r1500159 - /kafka/site/downloads.html |
Fri, 05 Jul, 22:59 |
| jun...@apache.org |
svn commit: r1500161 - /kafka/site/downloads.html |
Fri, 05 Jul, 23:02 |
| joest...@apache.org |
git commit: KAFKA-963 when publishing to maven repository central missing signature on everything |
Sun, 07 Jul, 13:20 |
| jun...@apache.org |
git commit: kafka-964; Default hadoop-producer configs to request.required.acks = 1; Patched by Swapnil Ghike; reviewed by Jun Rao |
Mon, 08 Jul, 20:07 |
| jun...@apache.org |
[01/43] git commit: kafka-813; Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[02/43] git commit: kafka-813; (add the missing file) Minor cleanup in Controller; patched by Swapnil Ghike; reviewed by Neha Narkhede and Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[03/43] git commit: kafka-825; KafkaController.isActive() needs to be synchronized; patched by Jun Rao; reviewed by Neha Narkhede |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[04/43] git commit: kafka-791; Fix validation bugs in System Test; patched by John Fung; reviewed by Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[05/43] git commit: KAFKA-830 partition replica assignment map in the controller should be a Set; reviewed by Jun Rao and Swapnil Ghike |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[06/43] git commit: kafka-819; System Test : Add validation of log segment index to offset; patched by John Fung; reviewed by Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[07/43] git commit: KAFKA-828 Preferred Replica Election does not delete the admin path on controller failover; reviewed by Neha Narkhede and Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[08/43] git commit: Missing file from KAFKA-828 |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[09/43] git commit: KAFKA-829 Mirror maker needs to share the migration tool request channel; reviewed by Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[10/43] git commit: KAFKA-831 Controller does not send the complete list of partitions to a newly started broker; reviewed by Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[11/43] git commit: kafka-832; 0.8 Consumer prevents rebalance if consumer thread is blocked or slow; patched by Jun Rao; reviewed by Neha Narkhede |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[12/43] git commit: KAFKA-831 Controller does not send the complete list of partitions to a newly started broker; reviewed by Jun Rao and Swapnil Ghike |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[13/43] git commit: kafka-807; LineMessageReader doesn't correctly parse the key separator; patched by Dragos Manolescu; reviewed by Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[14/43] git commit: trivial fix to print key properly in DumpLogSegments |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[15/43] git commit: KAFKA-840 Controller tries to perform preferred replica election on failover before state machines have started up; reviewed by Neha Narkhede |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[16/43] git commit: kafka-827; improve list topic output format; patched by Jun Rao; reviewed by Neha Narkhede |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[17/43] git commit: KAFKA-842 Mirror maker can lose some messages during shutdown; reviewed by Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[18/43] git commit: kafka-846; AbstractFetcherThread should do shallow instead of deep iteration; patched by Jun Rao; reviewed by Neha Narkhede |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[19/43] git commit: KAFKA-840 Post commit |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[20/43] git commit: KAFKA-844 System Test - Mirror Maker cases enhancements; reviewed by Neha Narkhede |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[21/43] git commit: KAFKA-851 Broken handling of leader and isr request leads to incorrect high watermark checkpoint file; reviewed by Jun Rao and Swapnil Ghike |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[22/43] git commit: 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 |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[23/43] git commit: kafka-850; add an option to show under replicated partitions in list topic command; patched by Jun Rao; reviewed by Neha Narkhede |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[24/43] git commit: KAFKA-858 High watermark values can be overwritten during controlled shutdown; reviewed by Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[25/43] git commit: kafka-649; Cleanup log4j logging; patched by Jun Rao; reviewed by Jay Kreps |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[26/43] git commit: 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 |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[27/43] git commit: KAFKA-860 Replica fetcher thread errors out and dies during rolling bounce of cluster; reviewed by Jun Rao, Jay Kreps |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[28/43] git commit: kafka-843; Re-add the release-zip sbt target; patched by Cosmin Lehene; reviewed by Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[29/43] git commit: kafka-861; IndexOutOfBoundsException while fetching data from leader; patched by Sriram Subramanian; reviewed by Jun Rao and Neha Narkhede |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[30/43] git commit: kafka-843; (addendum) Re-add the release-zip sbt target; patched by Cosmin Lehene; reviewed by Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[31/43] git commit: kafka-866; Recover segment does shallow iteration to fix index causing inconsistencies; patched by Sriram Subramanian; reviewed by Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[32/43] git commit: KAFKA-870 hadoop-producer KafkaRecordWriter writes entire input buffer capacity, even when intended payload is smaller; reviewed by Neha Narkhede |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[33/43] git commit: KAFKA-872; Socket server should set send/recv socket buffer sizes; reviewed by Jun Rao. |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[34/43] git commit: kafka-871; Rename ZkConfig properties; patched by Swapnil Ghike; reviewed by Jun Rao |
Mon, 08 Jul, 23:14 |
| jun...@apache.org |
[35/43] git commit: kafka-880; NoLeaderPartitionSet should be cleared before leader finder thread is started up; patched by Jun Rao; reviewed by Neha Narkhede |
Mon, 08 Jul, 23:15 |
| jun...@apache.org |
[36/43] git commit: Trivial commit - warn on consumer fetch request errors. |
Mon, 08 Jul, 23:15 |
| jun...@apache.org |
[37/43] git commit: change to standardize on [%s,%d] for partition |
Mon, 08 Jul, 23:15 |
| jun...@apache.org |
[38/43] git commit: KAFKA-887 Standardize logging for partition information to [%s,%d] format; reviewed by Swapnil and Jun |
Mon, 08 Jul, 23:15 |
| jun...@apache.org |
[39/43] git commit: KAFKA-890 The list of brokers for fetching metadata should be shuffled; reviewed by Joel Koshy |
Mon, 08 Jul, 23:15 |
| jun...@apache.org |
[40/43] git commit: 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 |
Mon, 08 Jul, 23:15 |
| jun...@apache.org |
[41/43] git commit: KAFKA-892 Change request log to include request completion not handling; reviewed by Joel Koshy |
Mon, 08 Jul, 23:15 |
| jun...@apache.org |
[42/43] git commit: kafka-896; merge 0.8 (988d4d8e65a14390abd748318a64e281e4a37c19) to trunk; patched by Jun Rao; reviewed by Jay Kreps |
Mon, 08 Jul, 23:15 |
| jun...@apache.org |
[43/43] git commit: Merge branch 'trunk' of https://git-wip-us.apache.org/repos/asf/kafka into trunk |
Mon, 08 Jul, 23:15 |
| jun...@apache.org |
git commit: kafka-969; Need to prevent failure of rebalance when there are no brokers available when consumer comes up; patched by Sriram Subramanian; reviewed by Joel Koshy and Jun Rao |
Thu, 11 Jul, 05:48 |
| jun...@apache.org |
[01/40] KAFKA-901 Kafka server can become unavailable if clients send several metadata requests; reviewed by Jun Rao |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[02/40] git commit: KAFKA-901 Kafka server can become unavailable if clients send several metadata requests; reviewed by Jun Rao |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[03/40] git commit: KAFKA-901: Follow up minor changes |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[04/40] git commit: KAFKA-901 follow up changes to fix update metadata response handling and request logging |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[05/40] git commit: Minor logging fix |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[06/40] git commit: kafka-907; controller needs to close socket channel to brokers on exception ; patched by Jun Rao; reviewed by Neha Narkhede |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[07/40] git commit: KAFKA-914; Break deadlock between initial rebalance and watcher-triggered rebalances; reviewed by Jun Rao and Neha Narkhede |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[08/40] git commit: kafka-919; Disabling of auto commit is ignored during consumer group rebalancing; patched by Phil Hargett; reviewed by Jun Rao |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[09/40] git commit: KAFKA-916; Break deadlock between fetcher shutdown and error partition handling; reviewed by Jun Rao. |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[10/40] git commit: KAFKA-922 System Test - set retry.backoff.ms=300 to testcase_0119; reviewed by Neha Narkhede |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[11/40] git commit: kafka-900; ClosedByInterruptException when high-level consumer shutdown normally; patched by Jun Rao; reviewed by Neha Narkhede |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[12/40] git commit: kafka-649; Cleanup log4j logging (extra); patched by Jun Rao; reviewed by Neha Narkhede |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[13/40] git commit: KAFKA-923 Improve controller failover latency. Remove unnecessary zookeeper reads; reviewed by Jun Rao |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[14/40] git commit: kafka-259; Give better error message when trying to run shell scripts without having built/downloaded the jars yet; patched by Ashwanth Fernando; reviewed by Jun Rao |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[15/40] git commit: trivial change to fix incorrect comment in Message |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[16/40] git commit: kafka-856; Correlation id for OffsetFetch request (#2) always responds with 0; patched by Milosz Tanski; reviewed by Jun Rao |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[17/40] git commit: kafka-920; zkclient jar 0.2.0 is not compatible with 0.1.0; patched by Jun Rao; reviewed by Neha Narkhede |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[18/40] git commit: kafka-899; LeaderNotAvailableException the first time a new message for a partition is processed; patched by Jun Rao; reviewed by Neha Narkhede |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[19/40] git commit: KAFKA-921; Expose max lag and min fetch rate mbeans for consumers and replica fetchers; reviewed by Jun Rao. |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[20/40] git commit: KAFKA-928 new topics may not be processed after ZK session expiration in controller; reviewed by Jun Rao |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[21/40] git commit: kafka-927; Integrate controlled shutdown into kafka shutdown hook; patched by Sriram Subramanian; reviewed by Neha Narkhede and Jun Rao |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[22/40] git commit: kafka-903; Attempt to swap the new high watermark file with the old one failed on Windows; patched by Jun Rao; reviewed by Neha Narkhede, Jay Kreps and Sriram Subramania |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[23/40] git commit: KAFKA-905 Logs can have same offsets causing recovery failure; reviewed by Jun, Neha and Jay |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[24/40] git commit: kafka-931; make zookeeper.connect a required property; patched by Jun Rao; reviewed by Neha Narkhede |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[25/40] git commit: KAFKA-935: Fix shutdown tool to work with new controlled shutdown API; reviewed by Neha Narkhede |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[26/40] git commit: trival change to review unneeded error logging since an exception is already thrown to the caller |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[27/40] git commit: kafka-938; High CPU usage when more or less idle; patched by Sam Meder; reviewed by Jun Rao |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[28/40] git commit: kafka-940; Scala match error in javaapi.Implicits; patched by Joel Koshy; reviewed by Jun Rao |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[29/40] git commit: kafka-937; ConsumerFetcherThread can deadlock; patched by Jun Rao; reviewed by Joel Koshy |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[30/40] git commit: KAFKA-941 Add Apache 2.0 license to missing code source files |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[31/40] git commit: trival change to increase default producer request timeout |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[32/40] git commit: KAFKA-942 version jar name change for 0.8.0-beta1 release |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[33/40] git commit: KAFKA-944 fixing up for release pom output from publish and publish-local is not accurate |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[34/40] git commit: kafka-947; isr-expiration-thread may block LeaderAndIsr request for a relatively long period; patched by Jun Rao; reviewed by Joel Koshy |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[35/40] git commit: kafka-951; Leader election rate may be reported on a non-controller; patched by Jun Rao; reviewed by Swapnil Ghike |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[36/40] git commit: kafka-950; Leader election rate may be reported on a non-controller; patched by Jun Rao; reviewed by Sriram Subramanian |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[37/40] git commit: kafka-937; fix bug exposed in ConsumerOffsetChecker; patched by Jun Rao; reviewed by Alexey Ozeritskiy |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[38/40] git commit: KAFKA-963 when publishing to maven repository central missing signature on everything |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[39/40] git commit: kafka-964; Default hadoop-producer configs to request.required.acks = 1; Patched by Swapnil Ghike; reviewed by Jun Rao |
Thu, 11 Jul, 06:37 |
| jun...@apache.org |
[40/40] git commit: kafka-965; merge c39d37e9dd97bf2462ffbd1a96c0b2cb05034bae from 0.8 to trunk; patched by Jun Rao; reviewed by Jay Kreps |
Thu, 11 Jul, 06:37 |
| jkr...@apache.org |
svn commit: r1502335 - in /kafka/site: 08/ops.html includes/header.html styles.css |
Thu, 11 Jul, 19:32 |
| jkr...@apache.org |
svn commit: r1502375 - /kafka/site/08/ops.html |
Thu, 11 Jul, 21:40 |
| jkr...@apache.org |
git commit: KAFKA-852, remove clientId from Offset{Fetch, Commit}Response. Reviewed by Jay. |
Thu, 11 Jul, 22:37 |
| joest...@apache.org |
git commit: KAFKA-974 can't use public release maven repo because of failure of downloaded dependency |
Mon, 15 Jul, 01:21 |
| jkr...@apache.org |
svn commit: r1503368 - in /kafka/site: 08/ops.html diagrams/kafka_multidc.graffle diagrams/kafka_multidc_complex.graffle diagrams/kafka_multidc_simple.graffle images/kafka_multidc_complex.png |
Mon, 15 Jul, 17:59 |
| jun...@apache.org |
git commit: kafka-347; change number of partitions of a topic online; patched by Sriram Subramanian; reviewed by Neha Narkehede, Guozhang Wang, Joel Koshy and Jun Rao |
Tue, 23 Jul, 04:38 |
| jun...@apache.org |
git commit: kafka-879; In system test, read the new leader from zookeeper instead of broker log on completion of become-leader state transition; patched by John Fung; reviewed by Jun Rao |
Tue, 23 Jul, 16:36 |