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 <[email protected]> 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 <[email protected]> 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
> >
>