| clear query|facets|time |
Search criteria: .
Results from 51 to 60 from
1162 (0.115s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: a few questions about kafka usage - Kafka - [mail # user]
|
|
...For #1, yes, a server restart is needed to pick up the new config.For #2, which version of Kafka are your using?Thanks,JunOn Fri, May 3, 2013 at 1:55 PM, Yu, Libo wrote:> More detai...
|
|
|
Author: Jun Rao,
2013-05-06, 01:06
|
|
|
Re: Consumer in the mirror maker stop fetching logs - Kafka - [mail # user]
|
|
...Actually, do you see log entries like "begin rebalancing" in the consumerlog? Rebalancing can cause sockets to be closed. If you have too manyrebalancing, it's very likely caused by consumer...
|
|
|
Author: Jun Rao,
2013-05-06, 01:05
|
|
|
[KAFKA-896] merge 0.8 (988d4d8e65a14390abd748318a64e281e4a37c19) to trunk - Kafka - [issue]
|
|
...Files that have conflicts:# Unmerged paths:# (use "git add/rm <file>..." as appropriate to mark resolution)## both modified: core/src/main/scala/ka...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-896
Author: Jun Rao,
2013-05-04, 00:29
|
|
|
Re: Kafka broker not respecting log.roll.hours? - Kafka - [mail # user]
|
|
...Commented on the jira.Thanks,JunOn Thu, May 2, 2013 at 2:22 PM, Dan Frankowski wrote:> Someone pointed out a particularly easy fix: don't reuse files after a> restart. Done. I re...
|
|
|
Author: Jun Rao,
2013-05-03, 15:58
|
|
|
Re: Consumer in the mirror maker stop fetching logs - Kafka - [mail # user]
|
|
...The consumer hit the exception because the broker closed the socket. Whatdoes the broker log around the same time say? It should tell you the reasonwhy the broker closed the socket.Thanks,Ju...
|
|
|
Author: Jun Rao,
2013-05-03, 15:50
|
|
|
Re: consuming only half the messages produced - Kafka - [mail # user]
|
|
...In this case, you have a replication factor of 1. So, each partition hasonly 1 replica.There are two possibilities: (1) The producer didn't send all messages. (2)The producer successfully se...
|
|
|
Author: Jun Rao,
2013-05-02, 14:56
|
|
|
Re: code name for technology changes in 0.8? - Kafka - [mail # user]
|
|
...We don't have an official code-name. You may want to try sth like kafka-ng(next generation).Thanks,JunOn Wed, May 1, 2013 at 8:36 PM, Jason Rosenberg wrote:> Hi,>> I'm wonderi...
|
|
|
Author: Jun Rao,
2013-05-02, 05:18
|
|
|
Re: consuming only half the messages produced - Kafka - [mail # user]
|
|
...Partition is different from replicas. A topic can have one or morepartitions and each partition can have one or more replicas. A consumerconsumes data at partition level. In other words, a c...
|
|
|
Author: Jun Rao,
2013-05-02, 05:15
|
|
|
Re: [0.8] producing a msg to two brokers... - Kafka - [mail # user]
|
|
...There is one leader per partition. For details on how to use the 0.8 api,please see http://kafka.apache.org/08/api.htmlThanks,JunOn Wed, May 1, 2013 at 7:11 PM, Rob Withers wrote:> ...
|
|
|
Author: Jun Rao,
2013-05-02, 05:07
|
|
|
Re: Kafka wiki Documentation conventions - looking for feedback - Kafka - [mail # user]
|
|
...The following are sample encoder/decoder in java.class StringEncode implements Encoder { private String encoding = null; public StringEncoder(VerifiableProperties pro...
|
|
|
Author: Jun Rao,
2013-05-01, 21:37
|
|
|
|
