Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 131 to 140 from 460 (0.079s).
Loading phrases to help you
refine your search...
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
[expand - 3 more] - Re: Strange partitioning behavior with - 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
[expand - 1 more] - Re: LeaderNotAvailableException in - Kafka - [mail # user]
...Any exceptions you saw on the controller log?On Tue, Jun 10, 2014 at 2:23 PM, Prakash Gowri Shankor <[EMAIL PROTECTED]> wrote: ...
   Author: Guozhang Wang, 2014-06-10, 21:48
[expand - 3 more] - Re: message.max.bytes and mirrormaker tool - Kafka - [mail # user]
...You can try to reduce batch.num.messages first and see if the throughputgets affected.For your second question, we do not have a good solution to that since theoffsets are not consistent acr...
   Author: Guozhang Wang, 2014-06-09, 21:54
Re: Hadoop Summit Meetups - Kafka - [mail # user]
...Robert,Thanks for the description. Just want to clarify on some of the points(assuming one transaction may include multiple messages below):2) For the "one-to-one mapping" to work, does the ...
   Author: Guozhang Wang, 2014-06-09, 15:15
[expand - 8 more] - Re: question about synchronous producer - Kafka - [mail # user]
...I think I know what is the problem now. With ack=1 the server will respondto the producer once the messages are appended to the log, BUT appending tothe log does not guarantee the log is flu...
   Author: Guozhang Wang, 2014-06-08, 05:12
Re: NoReplicaOnlineException with - Kafka - [mail # dev]
...Hi,From the logs it seems you created the topic immediately after starting thebroker, and hence the controller has not fully catch up. Could you trycreating the topic until the broker log st...
   Author: Guozhang Wang, 2014-06-07, 20:05
[expand - 1 more] - Re: Getting the KafkaStream ID - Kafka - [mail # user]
...It is not easy to get the fetcher thread id from kafka stream. We do havethe mapping as a topicThreadIdAndQueues, but it is private to the consumerand not exposed to callers.GuozhangOn Fri, ...
   Author: Guozhang Wang, 2014-06-06, 16:18
Re: Message details - Kafka - [mail # user]
...Hi Achanta,Your use case is quite interesting. If I do not understand wrong you wantto use a transaction that atomically consume on message from a partitionand send it to another partition c...
   Author: Guozhang Wang, 2014-06-05, 22:18
Kafka (460)
mail # user (264)
mail # dev (124)
issue (72)
last 7 days (13)
last 30 days (49)
last 90 days (155)
last 6 months (276)
last 9 months (460)
Jun Rao (993)
Neha Narkhede (630)
"Neha Narkhede (412)
Jay Kreps (331)
"Jun Rao (277)
Guozhang Wang (224)
Joel Koshy (196)
Joe Stein (181)
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)