| clear query|facets|time |
Search criteria: .
Results from 1 to 9 from
9 (0.132s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: urgent request for kafka 0.8 - Kafka - [mail # dev]
|
|
...Please ignore the previous email. I have found the library version and gotthe jar files.Thanks,JaneOn Mon, Jan 28, 2013 at 11:30 AM, Jane Wang wrote:> I just updated my kafka 0.8 th...
|
|
|
Author: Jane Wang,
2013-01-28, 23:52
|
|
|
urgent request for kafka 0.8 - Kafka - [mail # dev]
|
|
...I just updated my kafka 0.8 this morning.After that I am not able to run kafka any more.The error msg I got is for producer:13/01/28 11:23:57 ERROR async.DefaultEventHandler: Failed to send ...
|
|
|
Author: Jane Wang,
2013-01-28, 19:31
|
|
|
Re: parittioner runtime error with kafka 0.8 - Kafka - [mail # dev]
|
|
...finally, I made the partitioner working after changing the partition key tobe string.and add the key.serializer.class to the config props. thanks for the help.On Thu, Jan 17, 2013 at 7:57 PM...
|
|
|
Author: Jane Wang,
2013-01-18, 17:26
|
|
|
Re: parittioner runtime error with kafka 0.8 - Kafka - [mail # dev]
|
|
...I also tried with the constructorExpertSearchCollectionPartitioner(VerifiableProperties props) {}Still the same error.I also tried the constructor without any parameter and with parameter Lo...
|
|
|
Author: Jane Wang,
2013-01-18, 03:58
|
|
|
parittioner runtime error with kafka 0.8 - Kafka - [mail # dev]
|
|
...I defined a customized partitioner:class ExpertSearchCollectionPartitioner implements Partitioner { @Override public int partition(Long key, int numPartitions) { &...
|
|
|
Author: Jane Wang,
2013-01-18, 01:29
|
|
|
Re: weird partitioner behavior - Kafka - [mail # dev]
|
|
...I am still confused:(1) What I observed is that not only the first msg got wrong partitionnumber, but also the second message.(2) If kafka uses the first msg to get the co...
|
|
|
Author: Jane Wang,
2013-01-14, 21:56
|
|
|
Re: retrieving and deleting about topics - Kafka - [mail # dev]
|
|
...I tried to grep getMetadata from kafka 0.8. However, I failed to find it.does the api belong to a particular of kafka 0.8?Does this getMetadata an api belong to consumer?On Fri, Jan 11, 2013...
|
|
|
Author: Jane Wang,
2013-01-14, 21:26
|
|
|
kafka 0.8 vs. scala 2.9.2 - Kafka - [mail # dev]
|
|
...I need to use some of the newly added functions of kafka 0.8. However, inour system,we support scala 2.9.2. I build my code together kafka 0.8 and scala 2.9.2and I got alotof runtime issues,...
|
|
|
Author: Jane Wang,
2013-01-14, 21:22
|
|
|
periodically delete topics in version 0.8? - Kafka - [mail # dev]
|
|
...in kafka 0.8, is it possible for a consumer to send a request to the brokertodelete some topics? If yes, is it possible to provide some sample codesnippet to do it?I would highly appreciate ...
|
|
|
Author: Jane Wang,
2013-01-14, 18:20
|
|
|
|
