kafka-commits mailing list archives: July 2013

Site index · List index
Message list1 · 2 · Next »Thread · Author · Date
jjko...@apache.org git commit: KAFKA-957; MirrorMaker needs to preserve ordering for keyed messages from source cluster; patched by Guozhang Wang, reviewed by Joel Koshy Wed, 24 Jul, 18:43
jjko...@apache.org git commit: KAFKA-983; Expose MirrorMaker cleanShutdown method. Patched by Swapnil Ghike. Thu, 25 Jul, 01:06
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
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
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
jkr...@apache.org git commit: KAFKA-925 Add a partition key that overrides the message's stored key. Patch reviewed by Joel. Mon, 29 Jul, 22:34
joest...@apache.org git commit: KAFKA-963 when publishing to maven repository central missing signature on everything Sun, 07 Jul, 13:20
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
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
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
Message list1 · 2 · Next »Thread · Author · Date
Box list
Jun 2018253
May 2018152
Apr 2018139
Mar 2018225
Feb 2018250
Jan 2018168
Dec 2017114
Nov 2017334
Oct 2017262
Sep 2017250
Aug 2017189
Jul 2017194
Jun 2017511
May 2017339
Apr 2017168
Mar 2017147
Feb 2017317
Jan 2017294
Dec 2016152
Nov 2016110
Oct 2016268
Sep 2016182
Aug 2016132
Jul 2016138
Jun 2016121
May 2016327
Apr 2016257
Mar 2016199
Feb 2016139
Jan 2016157
Dec 2015118
Nov 2015388
Oct 2015224
Sep 201576
Aug 201578
Jul 201560
Jun 201537
May 201525
Apr 201565
Mar 201537
Feb 201590
Jan 201582
Dec 201423
Nov 201439
Oct 201483
Sep 201433
Aug 201468
Jul 201437
Jun 201423
May 201436
Apr 201478
Mar 201486
Feb 201496
Jan 201422
Dec 201322
Nov 201340
Oct 201363
Sep 201365
Aug 201335
Jul 2013108
Jun 201340
May 201327
Apr 201364
Mar 201382
Feb 201336
Jan 2013131
Dec 201265
Nov 201252
Oct 2012108
Sep 201268
Aug 201263
Jul 201237
Jun 201234
May 20129
Apr 201211
Mar 201220
Feb 201231
Jan 201222
Dec 201119
Nov 201127
Oct 201163
Sep 201126
Aug 201179
Jul 20115