Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 1 to 10 from 427 (0.05s).
Loading phrases to help you
refine your search...
Re: kafka consumer fail over - Kafka - [mail # user]
...Hello Weide,That should be doable via high-level consumer, you can take a look at thispage:https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+ExampleGuozhangOn Fri, Aug 1, 2014...
   Author: Guozhang Wang, 2014-08-01, 23:46
Re: Review Request 24006: Patch for KAFKA-1420 - Kafka - [mail # dev]
...This is an automatically generated e-mail. To reply, visit:https://reviews.apache.org/r/24006/#review49382core/src/test/scala/unit/kafka/admin/AdminTest.scala    RunningAsBrok...
2 emails [+ more]    Author: Guozhang Wang, 2014-08-01, 21:27
Re: find topic partition count through simpleclient api - Kafka - [mail # user]
...One seed broker should be enough, and the the number of partitionMetadatashould be the same as num. of partitions. One note here is that themetadata is propagated asynchronously to the broke...
   Author: Guozhang Wang, 2014-08-01, 17:03
Re: Reading messages offset in Apache Kafka - Kafka - [mail # user]
...Hi Anand,You can use the high-level consumer and turn of auto.offset.commit, and dosth. like:message = consumer.iter.next();bool acked = falsewhile (!acked) {process(message)acked = writeToD...
   Author: Guozhang Wang, 2014-08-01, 15:17
Re: Consume more than produce - Kafka - [mail # user]
...What is the ack value used in the producer?On Fri, Aug 1, 2014 at 1:28 AM, Guy Doulberg wrote: ...
   Author: Guozhang Wang, 2014-08-01, 15:07
Re: Most common kafka client comsumer implementations? - Kafka - [mail # user]
...Hi Jim,Whether to use high level or simple consumer depends on your use case. Ifyou need to manually manage partition assignments among your consumers, oryou need to commit your offsets else...
   Author: Guozhang Wang, 2014-07-31, 15:16
Re: Changing the Replication Factor - Kafka - [mail # user]
...It is possible to change the replication factor by using the partitionreassignment tool:http://kafka.apache.org/documentation.html#basic_ops_increase_replication_factorbut it requires a manu...
   Author: Guozhang Wang, 2014-07-31, 15:06
[KAFKA-1420] Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests - Kafka - [issue]
...This is a follow-up JIRA from KAFKA-1389.There are a bunch of places in the unit tests where we misuse AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK to create topics, where TestU...
http://issues.apache.org/jira/browse/KAFKA-1420    Author: Guozhang Wang, 2014-07-30, 19:25
Re: Lost messages during leader election - Kafka - [mail # user]
...Good to know. The issue with initial replica factor = 1 is still a real bugthough, and I will probably fix it along with KAFKA-1430.GuozhangOn Tue, Jul 29, 2014 at 10:27 AM, Jad Naous wrote:...
15 emails [+ more]    Author: Guozhang Wang, 2014-07-29, 17:57
Re: request.required.acks in Async Mode - Kafka - [mail # user]
...request.required.acks and producer.mode (sync or async) are orthogonalconfigs, i.e. with async mode, the producer.send() call itself will not beblocking on acks from the servers, but its asy...
   Author: Guozhang Wang, 2014-07-29, 15:10
Sort:
project
Kafka (427)
type
mail # user (246)
mail # dev (118)
issue (63)
date
last 7 days (11)
last 30 days (68)
last 90 days (159)
last 6 months (283)
last 9 months (427)
author
Jun Rao (972)
Neha Narkhede (623)
"Neha Narkhede (412)
Jay Kreps (329)
"Jun Rao (277)
Guozhang Wang (207)
Joel Koshy (182)
Joe Stein (180)
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)