Hmm, Ross, that actually sounds more like a bug. Rather than fix it, I think we should just get rid of these numeric codes entirely, they are pretty obscure. I filed https://issues.apache.org/jira/browse/KAFKA-363
Should be a pretty easy one to fix... -Jay On Thu, May 31, 2012 at 5:59 PM, Ross Black <ross.w.bl...@gmail.com> wrote: > I just fell into the trap of using: > > Properties props = new Properties(); > props.put("compression.codec", 2); > ProducerConfig config = new ProducerConfig(props); > > instead of > > props.put("compression.codec", "2"); > > or (better because it forces a string) > > props.setProperty("compression.codec", "2"); > > Using an int value means that no compression occurs, and no errors/warnings > are emitted. > > Ross > > > > On 30 May 2012 13:45, Jun Rao <jun...@gmail.com> wrote: > > > Another thing is that if zk namespace is used, the namespace needs to be > > create manually using ZK client shell first. > > > > Thanks, > > > > Jun > > > > On Tue, May 29, 2012 at 8:01 AM, Jay Kreps <jay.kr...@gmail.com> wrote: > > > > > There was a question about getting the exception when the consumer > > doesn't > > > have any metadata, which is normal. I was going to document that. > > Anything > > > else I should add? > > > > > > -Jay > > > > > >