kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Bill Bejeck <b...@confluent.io>
Subject Re: org.apache.kafka.streams.processor.TimestampExtractor#extract method in version 2.3 always returns -1 as value
Date Wed, 26 Jun 2019 14:15:41 GMT
Hi Jonathan,

Thanks for reporting this.  Which timestamp extractor are you using in the
configs?

Thanks,
Bill

On Wed, Jun 26, 2019 at 9:14 AM Jonathan Santilli <
jonathansantilli@gmail.com> wrote:

> Hello, hope you all are doing well,
>
> am testing the new version 2.3 for Kafka Streams specifically. I have
> noticed that now, the implementation of the method extract from the
> interface org.apache.kafka.streams.processor.TimestampExtractor
>
> *public* *long* extract(ConsumerRecord<Object, Object> record, *long*
> previousTimestamp)
>
>
> is always returning -1 as value.
>
>
> Previous version 2.2.1 was returning the correct value for the record
> partition.
>
> Am aware the interface is market as @InterfaceStability.Evolving and we
> should not rely on the stability/compatibility. Am just wondering if that
> new behavior is intentional or is a bug.
>
>
> Cheers!
> --
> Santilli Jonathan
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message