Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 81 to 90 from 418 (0.066s).
Loading phrases to help you
refine your search...
Re: SimpleConsumer dynamic read from all partition ? - Kafka - [mail # user]
...Short answer is no. Simple consumer has to know the partition ids inadvance to fetch the data. If you want dynamic partition assignments youneed to use high-level consumer.GuozhangOn Thu, Ju...
   Author: Guozhang Wang, 2014-06-19, 15:09
Re: Running mirrormaker in HA? - Kafka - [mail # user]
...Hi Prakash,Actually the MM is HA such that it used a consumer group fetching data fromthe source DC and another producer pushing them to the destination DC. Sosuppose there are two instances...
   Author: Guozhang Wang, 2014-06-18, 20:46
Re: MirrorMaker documentation suggestions - Kafka - [mail # user]
...Thanks Daniel for the findings, please feel free to update the wiki.GuozhangOn Tue, Jun 17, 2014 at 9:56 PM, Daniel Compton wrote: ...
   Author: Guozhang Wang, 2014-06-18, 05:39
Re: Use Kafka To Send Files - Kafka - [mail # user]
...We have seen people sending files with tens of MB size like messages (i.e.one file as a single message) using Kafka.GuozhangOn Sun, Jun 15, 2014 at 7:41 PM,  wrote: ...
   Author: Guozhang Wang, 2014-06-16, 03:47
Re: Kafka High Level Consumer Fail Over - Kafka - [mail # dev]
...I did not see any attachments in either emails?GuozhangOn Fri, Jun 13, 2014 at 1:36 PM, Bhavesh Mistry wrote: ...
   Author: Guozhang Wang, 2014-06-13, 20:54
[KAFKA-1487] add test jars to gradle build for packaging and release - Kafka - [issue]
...From Jacob Homan:"I don't see the 8.1.1 test jar in the ASF repo (https://repository.apache.org/index.html#nexus-search;gav~org.apache.kafka~kafka_2.9.1~~~~kw,versionexpand), nor the Scala 2...
http://issues.apache.org/jira/browse/KAFKA-1487    Author: Guozhang Wang, 2014-06-13, 19:00
Re: Recovering from consumer failure - Kafka - [mail # user]
...For some reason, your committed offsets are no longer in the zknode:org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode =NoNode for /consumers/mytopic_group/offsets/mytopic...
   Author: Guozhang Wang, 2014-06-13, 16:59
Re: scala based service/deamon consumer example - Kafka - [mail # user]
...You may want to read this wiki:https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+ExampleGuozhangOn Thu, Jun 12, 2014 at 11:13 AM, S Ahmed  wrote: ...
   Author: Guozhang Wang, 2014-06-12, 20:13
Re: Strange partitioning behavior with 0.8.1.1 - Kafka - [mail # user]
...In console producer you can specify the producer properties in command lineas metadata-expiry-ms.You can type just ./kafka-console-producer.sh and it will show you all theconfigs that you ca...
   Author: Guozhang Wang, 2014-06-11, 21:25
[KAFKA-1472] Add the compression ratio metrics in the new producer - Kafka - [issue]
...New producer's bytes throughput is based on compressed data. With the current implementation, it would be very easy to get the compression ratio of each closed batch upon drain(). It would b...
http://issues.apache.org/jira/browse/KAFKA-1472    Author: Guozhang Wang, 2014-06-11, 01:11
Sort:
project
Kafka (418)
type
mail # user (239)
mail # dev (117)
issue (62)
date
last 7 days (14)
last 30 days (61)
last 90 days (158)
last 6 months (279)
last 9 months (418)
author
Jun Rao (972)
Neha Narkhede (624)
"Neha Narkhede (412)
Jay Kreps (327)
"Jun Rao (277)
Guozhang Wang (201)
Joe Stein (180)
Joel Koshy (179)
John Fung (95)
"Joe Stein (94)
"Jay Kreps (90)
"Guozhang Wang (89)
Jason Rosenberg (70)
Swapnil Ghike (62)
David Arthur (61)
"Sriram Subramanian (60)
None (60)
Chris Burroughs (58)
"Swapnil Ghike (52)
"John Fung (39)
"Joel Koshy (38)
Timothy Chen (32)
Sriram Subramanian (30)
Alan D. Cabrera (24)
"Jason Rosenberg (20)