itten. 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
> wrote:
>
>> Added the project.
>>
>> On
Added the project.
On Thu, May 26, 2016 at 9:25 AM, Shaolu Xu wrote:
> Hi Tom,
>
> The following is my producer and consumer configuration:
>
>- Producer:
>
>props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "
> 127.0.0.1:9090"
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.
>
> Thanks
>
> Tom Crayford
> Heroku Kafka
>
> On Wednesday, 25 May 2
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 wrote:
> Hi dev,
>
> Kafka version: 0.9.0 language: Java
>
> When using kafka, I can set a codec by setting the*
> compression.type=snappy *pr
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 usin
