| clear query|facets|time |
Search criteria: .
Results from 51 to 60 from
1246 (0.115s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: consumer can't consume data any more when change the number of kafka partitions - Kafka - [mail # user]
|
|
...Have you followed #6 and #7 in http://kafka.apache.org/faq.html?Thanks,JunOn Tue, Jun 4, 2013 at 10:04 PM, shangan chen wrote:> I do have more consumers than partitions, but I don't think...
|
|
|
Author: Jun Rao,
2013-06-05, 14:36
|
|
|
Re: shallow iteration - Kafka - [mail # user]
|
|
...Libo,Because of the encoder/decoder api change, it's a bit hard to supportshallow iteration in 0.8. So, currently, one can't do shallow iteration. Wecan think about how to enable it again in...
|
|
|
Author: Jun Rao,
2013-06-05, 04:42
|
|
|
Re: Kafka Hadoop Consumer for multiple brokers - Kafka - [mail # user]
|
|
...The idea is that each mapper is only connecting to a single Kafka broker.Each line in the input file specifies broker uri, topic, partition andoffset.The hadoop consumer in contrib is probab...
|
|
|
Author: Jun Rao,
2013-06-04, 15:11
|
|
|
Re: Help with kafka-hadoop loader pipeline ??? - Kafka - [mail # user]
|
|
...I am not familiar with the hadoop loader that you are using. At LinkedIn,we are using https://github.com/linkedin/camus. It has an 0.8implementation too: https://github.com/linkedin/camus/tr...
|
|
|
Author: Jun Rao,
2013-06-04, 14:54
|
|
|
Re: Code Example for createMessageStreams - Kafka - [mail # user]
|
|
...For 0.8, you can find the example in the following wiki.https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+ExampleThanks,JunOn Tue, Jun 4, 2013 at 12:56 AM, Vadim Keylis ...
|
|
|
Author: Jun Rao,
2013-06-04, 14:51
|
|
|
Re: Send multiple messages to multiple topics in one request - Kafka - [mail # user]
|
|
...Yes, your understanding is correct.Thanks,JunOn Tue, Jun 4, 2013 at 12:36 AM, Vadim Keylis wrote:> Version 7 of Kafka allowed to send messages to multiple topics within one> requ...
|
|
|
Author: Jun Rao,
2013-06-04, 14:50
|
|
|
Re: Streaming across data centers - Kafka - [mail # user]
|
|
...You can read the following wiki on the MirrorMaker tool.https://cwiki.apache.org/confluence/display/KAFKA/Kafka+mirroring+%28MirrorMaker%29Thanks,JunOn Mon, Jun 3, 2013 at 10:58 PM, Guy Doul...
|
|
|
Author: Jun Rao,
2013-06-04, 14:48
|
|
|
[KAFKA-931] make zookeeper.connect a required property - Kafka - [issue]
|
|
...Currently, zookeeper.connect defaults to a null string. If this property is not overwritten, we will see weird NullPointerException in ZK. It will be better to make zookeeper.connect require...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-931
Author: Jun Rao,
2013-06-04, 02:41
|
|
|
[KAFKA-928] new topics may not be processed after ZK session expiration in controller - Kafka - [issue]
|
|
...When controller loses its ZK session, it calls partitionStateMachine.shutdown in SessionExpirationListener, which marks the partitionStateMachine as down. However, when the controller regain...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-928
Author: Jun Rao,
2013-06-03, 22:09
|
|
|
Re: consumer can't consume data any more when change the number of kafka partitions - Kafka - [mail # user]
|
|
...From the following log, it seems that you have more consumers thanpartitions. So, some consumers will never get any data. Please see #4 inhttp://kafka.apache.org/faq.html for details.13/06/0...
|
|
|
Author: Jun Rao,
2013-06-03, 15:25
|
|
|
|
