Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 1 to 10 from 17 (0.104s).
Loading phrases to help you
refine your search...
Message size issue - Kafka - [mail # user]
...Hi,I am getting an exception while working with a text file.kafka.common.MessageSizeTooLargeException: payload size of 1839314 largerthan 1000000atkafka.message.ByteBufferMessageSet.verifyMe...
   Author: navneet sharma, 2013-04-19, 06:18
Re: Non-blocking Kafka stream iterators - Kafka - [mail # user]
...Is there any property to make consumer work for lets say only 10 mins (iesome kind of timer)So, i want to close the consumer after 10 mins reading from broker..Thanks,Navneet SharmaOn Mon, J...
   Author: navneet sharma, 2013-01-21, 07:03
Re: hadoop-consumer code in contrib package - Kafka - [mail # user]
...That makes sense.I tried an alternate approach- i am using high level consumer and goingthrough Hadoop HDFS APIs and pushing data in HDFS.I am not creating any jobs for that.The only problem...
   Author: navneet sharma, 2013-01-17, 14:21
Re: SyncProducer vs Producer - Kafka - [mail # user]
...If that is the case:"Producer is actually the client api that everyoneshould be using."Then why contrib/hadoop-consumer is using SynProducer. Can i modify thecode to use Producer?Will it hav...
   Author: navneet sharma, 2013-01-15, 07:50
Re: Sending any other object (instead of Message) - Kafka - [mail # user]
...hi Jun,  is there any example to follow? I tried your suggestion but looks like i am missing something..  Thanks, Navneet Sharma  On Thu, Jun 21, 2012 at 1:56 AM, Jun Rao &nbs...
   Author: navneet sharma, 2012-06-28, 09:39
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: 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
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
Kafka (17)
mail # user (17)
last 7 days (0)
last 30 days (0)
last 90 days (0)
last 6 months (0)
last 9 months (17)
Jun Rao (968)
Neha Narkhede (624)
"Neha Narkhede (412)
Jay Kreps (327)
"Jun Rao (277)
Guozhang Wang (201)
Joe Stein (180)
Joel Koshy (179)
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)
navneet sharma