Interesting. Well, i'd say open issue in Sarama's github, probably you'll
find answers/ideas faster.
On Wed, Jul 25, 2018 at 7:51 PM Craig Ching wrote:
> This didn’t fix my problem unfortunately. Both time stamps are 0.
>
>
> > On Jul 24, 2018, at 15:22, Craig Ching wrote:
> >
> > Hey, thanks
This didn’t fix my problem unfortunately. Both time stamps are 0.
> On Jul 24, 2018, at 15:22, Craig Ching wrote:
>
> Hey, thanks for that Dmitriy! I'll have a look.
>
>> On Tue, Jul 24, 2018 at 11:18 AM Dmitriy Vsekhvalnov
>> wrote:
>> Not really associated with Sarama.
>>
>> But your is
Hey, thanks for that Dmitriy! I'll have a look.
On Tue, Jul 24, 2018 at 11:18 AM Dmitriy Vsekhvalnov
wrote:
> Not really associated with Sarama.
>
> But your issues sounds pretty much same i faced some time ago and fixed,
> here it is: https://github.com/Shopify/sarama/issues/885
>
> Try using
Not really associated with Sarama.
But your issues sounds pretty much same i faced some time ago and fixed,
here it is: https://github.com/Shopify/sarama/issues/885
Try using msg.BlockTimestamp instead of msg.Timestamp and see if it helps.
On Tue, Jul 24, 2018 at 3:26 AM Craig Ching wrote:
> H
Hi Dmitry,
Are you associated with the Sarama project? If so, understand that part of
what I want is to learn about Sarama and the Kafka message format ;)
The problem I'm having is that if I turn on:
log.message.timestamp.type=LogAppendTime
in the broker, then produce on topic1 with console pr
Hey Craig,
what exact problem you have with Sarama client?
On Mon, Jul 23, 2018 at 5:11 PM Craig Ching wrote:
> Hi!
>
> I'm working on debugging a problem with how message timestamps are handled
> in the sarama client. In some cases, the sarama client won't associate a
> timestamp with a messa
Hi!
I'm working on debugging a problem with how message timestamps are handled
in the sarama client. In some cases, the sarama client won't associate a
timestamp with a message while the kafka console consumer does. I've found
the documentation on the message format here:
https://kafka.apache.o
