| clear query|facets|time |
Search criteria: .
Results from 11 to 20 from
34 (0.135s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: Consumer exception - Kafka - [mail # user]
|
|
...Thanks Jun, i got it. Somehow i overlooked "iter.next().message()" . What confused me more is that when iterator is ConsumerIterator , how its returning MessageAndMetadata. Whats the r...
|
|
|
Author: navneet sharma,
2012-06-06, 17:59
|
|
|
Re: Consumer exception - Kafka - [mail # user]
|
|
...Hi Jun, Just to make sure that i have updated code, i updated source code just now from this location: http://svn.apache.org/repos/asf/incubator/kafka/trunk but i am not seeing &...
|
|
|
Author: navneet sharma,
2012-06-06, 06:13
|
|
|
Re: Consumer exception - Kafka - [mail # user]
|
|
...yes of course, the code snippet which i posted is from the kafka.examples.Consumer only. Its not modified to use MessageAndMetadata. Has it been changed in last week? Thank...
|
|
|
Author: navneet sharma,
2012-06-06, 03:49
|
|
|
Consumer exception - Kafka - [mail # user]
|
|
...Hi, I downloaded the latest code from trunk last week and i was trying this snippet as given in examples. Map topicCountMap = new HashMap(); topicCountMap.put(topi...
|
|
|
Author: navneet sharma,
2012-06-05, 13:33
|
|
|
Re: java.lang.RuntimeException: Invalid magic byte 6 - Kafka - [mail # user]
|
|
...just to confirm - is this project an integration of kafka with storm? The page doesnt provide much details. Thanks, Navneet Sharma On Mon, May 21, 2012 at 8:21 PM, Jun Rao ...
|
|
|
Author: navneet sharma,
2012-05-26, 05:29
|
|
|
Re: Duplicate messages after new consumer introduction - Kafka - [mail # user]
|
|
...I downloaded the tar from the download link provided in quickstart page. Almost more than a month back. I trunk maintaining different code than the tar? Can number of partitions ...
|
|
|
Author: navneet sharma,
2012-05-17, 06:45
|
|
|
Duplicate messages after new consumer introduction - Kafka - [mail # user]
|
|
...Hi, I tried a scenario wherein: 1) i had 1 producer and 3 consumers subscribed for a topic - "cartTopic", all in same group. 2) Now, when everything is executing, i introduced another ...
|
|
|
Author: navneet sharma,
2012-05-16, 09:41
|
|
|
Re: Tailing a syslog - Kafka - [mail # user]
|
|
...Jay, is there any example or documentation to understand how to use it. If i type something on console, it will be captured by producer, but how to send messages from a syslog to this ...
|
|
|
Author: navneet sharma,
2012-05-15, 13:07
|
|
|
Re: Exception from consumer - Kafka - [mail # user]
|
|
...Jun, Deleting zookeeper directory or broker logs is problematic and should not be done. How about killing a consumer process? Since, its in a infinite loop, i can't see any other...
|
|
|
Author: navneet sharma,
2012-05-15, 13:04
|
|
|
Re: Exception from consumer - Kafka - [mail # user]
|
|
...i deleted the broker log file and that fixed the problem. But is there any better way to fix? On Fri, May 11, 2012 at 12:39 PM, navneet sharma wrote: ...
|
|
|
Author: navneet sharma,
2012-05-11, 08:05
|
|
|
|
