Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)

2015-01-24 Thread Joe Stein
That makes sense, thanks! On Sat, Jan 24, 2015 at 7:00 PM, Jay Kreps wrote: > But I think the flaw in trying to guess what kind of serializer they will > use is when we get it wrong. Basically let's say we guess "String". Say 30% > of the time we will be right and we will save the two configurat

Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)

2015-01-24 Thread Jay Kreps
But I think the flaw in trying to guess what kind of serializer they will use is when we get it wrong. Basically let's say we guess "String". Say 30% of the time we will be right and we will save the two configuration lines. 70% of the time we will be wrong and the user gets a super cryptic ClassCa

Re: [kafka-clients] Re: [VOTE] 0.8.2.0 Candidate 2 (with the correct links)

2015-01-24 Thread Joe Stein
Maybe. I think the StringSerialzer could look more like a typical type of message. Instead of encoding being a property it would be more typically just written in the bytes. On Sat, Jan 24, 2015 at 12:12 AM, Jay Kreps wrote: > I don't think so--see if you buy my explanation. We previously defau

Re: no brokers found when trying to rebalance

2015-01-24 Thread Tim Smith
Yes, turns out that during the upgrade from CDH5.2 to CDH5.3, the namespace changed from "/kafka" to simply "/" on Zk. I spoke with the developers over at Cloudera and they said, using "/" seemed to be the convention. I am going to open a case with them to clearly document the change so other custo

ERROR Closing socket for /IP because of error (kafka.network.Processor)

2015-01-24 Thread Mahesh Sankaran
Hi all, I am currently working on logstash to mongodb.logstash's input (producer) is kafka and output (consumer) is mongodb.It is worked fine for past two days.Today it is not working and i got the following error.i googled this error,still didnt find any correct solution.kindly help me to r