kafka-users mailing list archives: August 2014

Site index · List index
Message list« Previous · 1 · 2 · 3 · Next »Thread · Author · Date
Bhavesh Mistry [Kafka MirrorMaker] Message with Custom Partition Logic Mon, 11 Aug, 20:21
Chen Wang Issue with 240 topics per day Mon, 11 Aug, 21:19
Todd Palino   Re: Issue with 240 topics per day Mon, 11 Aug, 22:47
Chen Wang     Re: Issue with 240 topics per day Mon, 11 Aug, 23:45
Philip O'Toole       Re: Issue with 240 topics per day Tue, 12 Aug, 00:01
Chen Wang         Re: Issue with 240 topics per day Tue, 12 Aug, 00:18
Philip O'Toole           Re: Issue with 240 topics per day Tue, 12 Aug, 01:07
Chen Wang             Re: Issue with 240 topics per day Tue, 12 Aug, 01:42
Philip O'Toole               Re: Issue with 240 topics per day Tue, 12 Aug, 01:53
Todd Palino       Re: Issue with 240 topics per day Tue, 12 Aug, 04:02
Chen Wang         Re: Issue with 240 topics per day Tue, 12 Aug, 04:20
Todd Palino           Re: Issue with 240 topics per day Tue, 12 Aug, 04:31
Chen Wang             Re: Issue with 240 topics per day Tue, 12 Aug, 04:39
Philip O'Toole             Re: Issue with 240 topics per day Tue, 12 Aug, 15:28
Chen Wang   Re: Issue with 240 topics per day Tue, 12 Aug, 02:34
vipul jhawar     Re: Issue with 240 topics per day Tue, 12 Aug, 03:04
Philip O'Toole     Re: Issue with 240 topics per day Tue, 12 Aug, 03:11
Chen Wang   Re: Issue with 240 topics per day Tue, 12 Aug, 03:21
Chen Wang   Re: Issue with 240 topics per day Tue, 12 Aug, 03:37
Mingtao Zhang Consumer Parallelism Mon, 11 Aug, 21:33
Mingtao Zhang   Re: Consumer Parallelism Mon, 11 Aug, 22:29
Guozhang Wang     Re: Consumer Parallelism Mon, 11 Aug, 23:37
Mingtao Zhang       Re: Consumer Parallelism Tue, 12 Aug, 01:27
Guozhang Wang         Re: Consumer Parallelism Tue, 12 Aug, 05:10
Mingtao Zhang           Re: Consumer Parallelism Tue, 12 Aug, 11:55
Mingtao Zhang             Re: Consumer Parallelism Tue, 12 Aug, 15:11
Guozhang Wang               Re: Consumer Parallelism Tue, 12 Aug, 16:22
Mingtao Zhang                 Re: Consumer Parallelism Tue, 12 Aug, 16:41
Guozhang Wang                   Re: Consumer Parallelism Tue, 12 Aug, 16:53
kafka TestUtils createBrokerConfig issue
Parin Jogani   kafka TestUtils createBrokerConfig issue Tue, 12 Aug, 15:14
Jun Rao     Re: kafka TestUtils createBrokerConfig issue Tue, 12 Aug, 16:25
Guozhang Wang     Re: kafka TestUtils createBrokerConfig issue Tue, 12 Aug, 16:32
Parin Jogani     Fwd: kafka TestUtils createBrokerConfig issue Tue, 19 Aug, 07:17
Parin Jogani   kafka TestUtils createBrokerConfig issue Tue, 19 Aug, 20:20
Jun Rao     Re: kafka TestUtils createBrokerConfig issue Thu, 21 Aug, 04:54
Steve Miller Using the kafka dissector in wireshark/tshark 1.12 Tue, 12 Aug, 18:03
Neha Narkhede   Re: Using the kafka dissector in wireshark/tshark 1.12 Wed, 13 Aug, 16:37
Jagbir Hooda Blocking Recursive parsing from kafka.consumer.TopicCount$.constructTopicCount Tue, 12 Aug, 18:48
Guozhang Wang   Re: Blocking Recursive parsing from kafka.consumer.TopicCount$.constructTopicCount Tue, 12 Aug, 23:35
Jagbir Hooda   RE: Blocking Recursive parsing from kafka.consumer.TopicCount$.constructTopicCount Wed, 13 Aug, 06:14
Jun Rao     Re: Blocking Recursive parsing from kafka.consumer.TopicCount$.constructTopicCount Wed, 13 Aug, 15:22
Jagbir Hooda   RE: Blocking Recursive parsing from kafka.consumer.TopicCount$.constructTopicCount Thu, 14 Aug, 01:48
Chen Wang Correct way to handle ConsumerTimeoutException Tue, 12 Aug, 21:27
Guozhang Wang   Re: Correct way to handle ConsumerTimeoutException Tue, 12 Aug, 23:37
Neha Narkhede     Re: Correct way to handle ConsumerTimeoutException Wed, 13 Aug, 16:35
Chen Wang       Re: Correct way to handle ConsumerTimeoutException Thu, 14 Aug, 17:27
Steve Miller Strange topic-corruption issue? Wed, 13 Aug, 00:42
Jun Rao   Re: Strange topic-corruption issue? Wed, 13 Aug, 15:15
Steve Miller     Re: Strange topic-corruption issue? Wed, 13 Aug, 18:40
Jun Rao       Re: Strange topic-corruption issue? Thu, 14 Aug, 18:22
Steve Miller         Re: Strange topic-corruption issue? Thu, 14 Aug, 21:11
Neha Narkhede           Re: Strange topic-corruption issue? Fri, 15 Aug, 00:04
Steve Miller             Re: Strange topic-corruption issue? Fri, 15 Aug, 12:27
Jun Rao               Re: Strange topic-corruption issue? Fri, 15 Aug, 23:00
Steve Miller                 Re: Strange topic-corruption issue? Sun, 17 Aug, 19:28
Andrew Longwill Consuming messages from Kafka and pushing on to a JMS queue Wed, 13 Aug, 13:06
Neha Narkhede   Re: Consuming messages from Kafka and pushing on to a JMS queue Wed, 13 Aug, 16:28
Josh J consumer read from specific partition Thu, 14 Aug, 08:46
Sharninder   Re: consumer read from specific partition Thu, 14 Aug, 10:23
Neha Narkhede     Re: consumer read from specific partition Thu, 14 Aug, 14:27
Josh J       Re: consumer read from specific partition Mon, 18 Aug, 13:57
Sharninder         Re: consumer read from specific partition Mon, 18 Aug, 15:07
Josh J           Re: consumer read from specific partition Mon, 18 Aug, 16:14
Jonathan Weeks             Re: consumer read from specific partition Mon, 18 Aug, 16:43
Josh J               Re: consumer read from specific partition Mon, 18 Aug, 16:50
Jonathan Weeks                 Re: consumer read from specific partition Mon, 18 Aug, 17:07
Chen Wang How many threads should I use per topic Thu, 14 Aug, 17:39
Joel Koshy   Re: How many threads should I use per topic Thu, 14 Aug, 18:51
Strong Liu erlang client for 0.8? Thu, 14 Aug, 17:50
Bosky   Re: erlang client for 0.8? Sat, 16 Aug, 06:33
Ryan Williams How to perform a controlled shutdown for rolling bounce? Thu, 14 Aug, 18:10
Joel Koshy   Re: How to perform a controlled shutdown for rolling bounce? Thu, 14 Aug, 18:40
Ryan Williams     Re: How to perform a controlled shutdown for rolling bounce? Thu, 14 Aug, 19:59
Joel Koshy       Re: How to perform a controlled shutdown for rolling bounce? Thu, 14 Aug, 20:14
Telles Nobrega Writing to Kafka Thu, 14 Aug, 19:03
Jay Kreps   Re: Writing to Kafka Thu, 14 Aug, 22:14
Prunier, Dominique Consumer sensitive expiration of topic Thu, 14 Aug, 21:56
Neha Narkhede   Re: Consumer sensitive expiration of topic Fri, 15 Aug, 00:10
Prunier, Dominique     RE: Consumer sensitive expiration of topic Fri, 15 Aug, 15:02
Prunier, Dominique       RE: Consumer sensitive expiration of topic Mon, 25 Aug, 21:25
Neha Narkhede         Re: Consumer sensitive expiration of topic Thu, 28 Aug, 03:35
Prunier, Dominique           RE: Consumer sensitive expiration of topic Thu, 28 Aug, 15:03
Jay Kreps             Re: Consumer sensitive expiration of topic Thu, 28 Aug, 16:28
Prunier, Dominique               RE: Consumer sensitive expiration of topic Thu, 28 Aug, 17:06
Gwen Shapira                 Re: Consumer sensitive expiration of topic Thu, 28 Aug, 19:23
Prunier, Dominique                   RE: Consumer sensitive expiration of topic Thu, 28 Aug, 19:29
Joel Koshy   Re: Consumer sensitive expiration of topic Fri, 15 Aug, 00:28
Andrew Longwill JMSXGroupID clustered message grouping Fri, 15 Aug, 16:42
Philip O'Toole   Re: JMSXGroupID clustered message grouping Fri, 15 Aug, 16:57
Roger Hoover How try out the new producer? Fri, 15 Aug, 18:00
Neha Narkhede   Re: How try out the new producer? Fri, 15 Aug, 18:22
Roger Hoover     Re: How try out the new producer? Fri, 15 Aug, 18:37
cac...@gmail.com   Re: How try out the new producer? Fri, 15 Aug, 18:23
Roger Hoover     Re: How try out the new producer? Fri, 15 Aug, 19:33
Jun Rao     Re: How try out the new producer? Fri, 15 Aug, 23:03
Roger Hoover       Re: How try out the new producer? Sat, 16 Aug, 00:52
Re: kafka 0.8.1.1 log.retention.minutes NOT being honored
François Langelier   Re: kafka 0.8.1.1 log.retention.minutes NOT being honored Fri, 15 Aug, 19:32
François Langelier     Re: kafka 0.8.1.1 log.retention.minutes NOT being honored Tue, 19 Aug, 15:12
Jun Rao     Re: kafka 0.8.1.1 log.retention.minutes NOT being honored Thu, 21 Aug, 04:50
François Langelier       Re: kafka 0.8.1.1 log.retention.minutes NOT being honored Thu, 21 Aug, 14:44
Jun Rao         Re: kafka 0.8.1.1 log.retention.minutes NOT being honored Thu, 21 Aug, 16:23
Vjeran Marcinko Embedded Kafka/Zookeeper for unit testing Sat, 16 Aug, 14:13
Steve Morin   Re: Embedded Kafka/Zookeeper for unit testing Sat, 16 Aug, 17:42
Bae, Jae Hyeon ZkClient bug can bring down broker/consumer on zookeeper push in EC2 environment Sun, 17 Aug, 18:41
Nishit Kumar Subscribe me Mon, 18 Aug, 12:41
Neha Narkhede   Re: Subscribe me Mon, 18 Aug, 20:55
François Langelier     Re: Subscribe me Mon, 18 Aug, 21:31
pradeep.si...@wipro.com Keep on getting kafka.common.OffsetOutOfRangeException: Random times Mon, 18 Aug, 12:49
Guozhang Wang   Re: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Mon, 18 Aug, 16:36
Neha Narkhede     Re: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Mon, 18 Aug, 20:56
pradeep.si...@wipro.com       RE: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Tue, 19 Aug, 03:59
pradeep.si...@wipro.com         RE: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Tue, 19 Aug, 09:12
Steve Miller           Re: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Tue, 19 Aug, 12:42
pradeep.si...@wipro.com             RE: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Wed, 20 Aug, 03:54
Steve Miller               Re: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Wed, 20 Aug, 07:47
Manjunath Shivakumar               RE: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Wed, 20 Aug, 08:01
pradeep.si...@wipro.com                 RE: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Wed, 20 Aug, 08:40
Philip O'Toole                   Re: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Wed, 20 Aug, 16:28
Steve Miller                     Re: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Wed, 20 Aug, 21:28
Philip O'Toole                       Re: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Thu, 21 Aug, 02:20
文峰                         Re: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Thu, 21 Aug, 05:08
Guozhang Wang                   Re: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Wed, 20 Aug, 16:35
Guozhang Wang           Re: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Tue, 19 Aug, 16:35
pradeep.si...@wipro.com             RE: Keep on getting kafka.common.OffsetOutOfRangeException: Random times Wed, 20 Aug, 03:50
Harsha kafka contrib/hadoop-consumer,producer Mon, 18 Aug, 17:02
Ivan Balashov How to shutdown/restart kafka cluster properly Mon, 18 Aug, 21:19
Joel Koshy   Re: How to shutdown/restart kafka cluster properly Tue, 19 Aug, 01:47
Justin Maltat Using kafka in non million users environment Mon, 18 Aug, 22:53
Daniel Compton   Re: Using kafka in non million users environment Tue, 19 Aug, 11:18
Justin Maltat     Re: Using kafka in non million users environment Tue, 19 Aug, 22:39
Philip O'Toole       Re: Using kafka in non million users environment Tue, 19 Aug, 22:59
Anand Nalya       Re: Using kafka in non million users environment Wed, 20 Aug, 07:49
Justin Maltat         Re: Using kafka in non million users environment Thu, 21 Aug, 05:18
Josh J kafka high level consumer - threads guaranteed to read a single partition? Tue, 19 Aug, 09:01
Guozhang Wang   Re: kafka high level consumer - threads guaranteed to read a single partition? Tue, 19 Aug, 16:23
Lian, Li how is the partitioner working when compression is enabled? Tue, 19 Aug, 13:46
Magnus Edenhill   Re: how is the partitioner working when compression is enabled? Tue, 19 Aug, 14:12
Guozhang Wang     Re: how is the partitioner working when compression is enabled? Tue, 19 Aug, 16:26
Re: Improving the Kafka client ecosystem
Mark Roberts   Re: Improving the Kafka client ecosystem Tue, 19 Aug, 16:02
Dana Powers     Re: Improving the Kafka client ecosystem Tue, 19 Aug, 16:08
Jay Kreps       Re: Improving the Kafka client ecosystem Tue, 19 Aug, 20:08
Joe Stein         Re: Improving the Kafka client ecosystem Tue, 19 Aug, 20:22
Joe Stein           Re: Improving the Kafka client ecosystem Tue, 19 Aug, 20:27
Gwen Shapira             Re: Improving the Kafka client ecosystem Tue, 19 Aug, 20:33
Joe Stein               Re: Improving the Kafka client ecosystem Tue, 19 Aug, 20:41
Fwd: Issue in using kafka SimpleConsumer code
pankaj ojha   Fwd: Issue in using kafka SimpleConsumer code Tue, 19 Aug, 18:01
Manjunath Shivakumar fsync behaviour Wed, 20 Aug, 01:00
Jun Rao   Re: fsync behaviour Thu, 21 Aug, 05:02
Manjunath Shivakumar     Re: fsync behaviour Thu, 21 Aug, 06:01
Manjunath Shivakumar   RE: fsync behaviour Thu, 21 Aug, 10:37
Jun Rao     Re: fsync behaviour Thu, 21 Aug, 14:40
Parin Jogani kafka TestUtils choosePort NoSuchMethodError Wed, 20 Aug, 05:37
siddharth ubale Data inputs for Kafka. Wed, 20 Aug, 12:04
Philip O'Toole   Re: Data inputs for Kafka. Wed, 20 Aug, 16:20
siddharth ubale     Re: Data inputs for Kafka. Thu, 21 Aug, 06:10
Sharninder       Re: Data inputs for Kafka. Thu, 21 Aug, 06:18
siddharth ubale         Re: Data inputs for Kafka. Thu, 21 Aug, 10:29
Sharninder           Re: Data inputs for Kafka. Thu, 21 Aug, 12:45
siddharth ubale             Re: Data inputs for Kafka. Thu, 21 Aug, 13:29
pankaj ojha Which is better? Wed, 20 Aug, 15:34
Philip O'Toole   Re: Which is better? Wed, 20 Aug, 16:24
Cory Watson Announce: Capillary, a monitor for Kafka 0.8 spout topologies Wed, 20 Aug, 16:32
Philip O'Toole   Re: Announce: Capillary, a monitor for Kafka 0.8 spout topologies Wed, 20 Aug, 17:04
Cory Watson     Re: Announce: Capillary, a monitor for Kafka 0.8 spout topologies Wed, 20 Aug, 17:13
Philip O'Toole       Re: Announce: Capillary, a monitor for Kafka 0.8 spout topologies -- and the upgrade to 0.8 Wed, 20 Aug, 17:17
Cory Watson         Re: Announce: Capillary, a monitor for Kafka 0.8 spout topologies -- and the upgrade to 0.8 Wed, 20 Aug, 17:31
Ashutosh Prasad Panigrahi Kafka Mirroring Issue Thu, 21 Aug, 07:09
Guozhang Wang   Re: Kafka Mirroring Issue Thu, 21 Aug, 15:22
Ashutosh Prasad Panigrahi     Re: Kafka Mirroring Issue Mon, 25 Aug, 10:18
François Langelier       Re: Kafka Mirroring Issue Mon, 25 Aug, 13:08
Ashutosh Prasad Panigrahi         Re: Kafka Mirroring Issue Mon, 25 Aug, 16:04
François Langelier           Re: Kafka Mirroring Issue Mon, 25 Aug, 17:29
Arjun doubt regarding High level consumer commiting offset Fri, 22 Aug, 11:18
Arjun   Re: doubt regarding High level consumer commiting offset Fri, 22 Aug, 14:59
Guozhang Wang     Re: doubt regarding High level consumer commiting offset Fri, 22 Aug, 15:44
chenlax read message use SimpleConsumer,can not start with assign offset Fri, 22 Aug, 14:36
Jun Rao   Re: read message use SimpleConsumer,can not start with assign offset Sat, 23 Aug, 04:27
chenlax   RE: read message use SimpleConsumer,can not start with assign offset Mon, 25 Aug, 02:24
Jun Rao     Re: read message use SimpleConsumer,can not start with assign offset Mon, 25 Aug, 02:58
chenlax       RE: read message use SimpleConsumer,can not start with assign offset Mon, 25 Aug, 03:16
Jun Rao         Re: read message use SimpleConsumer,can not start with assign offset Mon, 25 Aug, 04:41
chenlax   RE: read message use SimpleConsumer,can not start with assign offset Mon, 25 Aug, 08:55
chenlax   RE: read message use SimpleConsumer,can not start with assign offset Mon, 25 Aug, 10:46
Seshadri, Balaji Kafka build for Scala 2.11 Fri, 22 Aug, 18:02
Jonathan Weeks   Re: Kafka build for Scala 2.11 Fri, 22 Aug, 18:08
Seshadri, Balaji     RE: Kafka build for Scala 2.11 Fri, 22 Aug, 18:53
Joe Stein   Re: Kafka build for Scala 2.11 Fri, 22 Aug, 18:19
Jonathan Weeks     Re: Kafka build for Scala 2.11 Fri, 22 Aug, 18:23
Seshadri, Balaji     RE: Kafka build for Scala 2.11 Fri, 22 Aug, 19:00
François Langelier       Re: Kafka build for Scala 2.11 Fri, 22 Aug, 21:15
Igal Levy Please fix broken link and update blurb Fri, 22 Aug, 18:22
Gwen Shapira   Re: Please fix broken link and update blurb Fri, 22 Aug, 19:48
Ran RanUser restoring broker node without Zookeeper data? Sat, 23 Aug, 04:26
Jun Rao   Re: restoring broker node without Zookeeper data? Sat, 23 Aug, 04:33
Message list« Previous · 1 · 2 · 3 · Next »Thread · Author · Date
Box list
Oct 2019109
Sep 2019202
Aug 2019186
Jul 2019231
Jun 2019254
May 2019247
Apr 2019175
Mar 2019148
Feb 2019221
Jan 2019294
Dec 2018139
Nov 2018200
Oct 2018213
Sep 2018275
Aug 2018347
Jul 2018380
Jun 2018302
May 2018271
Apr 2018251
Mar 2018370
Feb 2018389
Jan 2018372
Dec 2017349
Nov 2017446
Oct 2017406
Sep 2017371
Aug 2017409
Jul 2017526
Jun 2017550
May 2017576
Apr 2017413
Mar 2017659
Feb 2017641
Jan 2017524
Dec 2016703
Nov 2016614
Oct 2016649
Sep 2016468
Aug 2016536
Jul 2016580
Jun 2016718
May 2016668
Apr 2016553
Mar 2016695
Feb 2016532
Jan 2016527
Dec 2015355
Nov 2015488
Oct 2015353
Sep 2015367
Aug 2015494
Jul 2015456
Jun 2015429
May 2015437
Apr 2015446
Mar 2015782
Feb 2015764
Jan 2015666
Dec 2014460
Nov 2014557
Oct 2014561
Sep 2014381
Aug 2014434
Jul 2014426
Jun 2014561
May 2014424
Apr 2014388
Mar 2014452
Feb 2014474
Jan 2014538
Dec 2013459
Nov 2013456
Oct 2013562
Sep 2013278
Aug 2013672
Jul 2013418
Jun 2013445
May 2013421
Apr 2013391
Mar 2013361
Feb 2013170
Jan 2013245
Dec 2012240
Nov 2012338
Oct 2012234
Sep 2012126
Aug 2012164
Jul 2012155
Jun 2012251
May 2012261
Apr 2012151
Mar 2012110
Feb 2012109
Jan 2012124
Dec 2011162
Nov 2011212
Oct 2011225
Sep 201169
Aug 201165
Jul 201140