hing further is written. Try using
> "earliest" for auto.offset.reset and see if that works. If not, attach some
> logs and we'll try to help.
>
> Thanks,
> Jason
>
> On Wed, May 25, 2016 at 6:37 PM, Shaolu Xu <sh...@tibco-support.com>
> wrote:
>
>> Added t
Added the project.
On Thu, May 26, 2016 at 9:25 AM, Shaolu Xu <sh...@tibco-support.com> wrote:
> Hi Tom,
>
> The following is my producer and consumer configuration:
>
>- Producer:
>
>props.put(ConsumerConfig.BOOTSTRAP_SERVERS
d <tcrayf...@heroku.com> wrote:
> Which consumer are you using? Can you see it connecting to the broker in
> the broker logs? I'd recommend putting your configs for producer, consumer
> and broker in a reply to assist debugging. Also please attach any relevant
> code or log files.
>
Hi All,
Anyone have idea about this, Please help me find the issue.
Thanks,
Nicole
On Wed, May 25, 2016 at 11:24 AM, Shaolu Xu <sh...@tibco-support.com> wrote:
> Hi dev,
>
> Kafka version: 0.9.0 language: Java
>
> When using kafka, I can set a codec by setting the*
>
Hi dev,
Kafka version: 0.9.0 language: Java
When using kafka, I can set a codec by setting the* compression.type=snappy
*property of my kafka producer.
Suppose I use snappy compression in my producer, and i can see the message
use kafkaMonitor. But when I consuming the messages from kafka
