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:40:00 GMT
Thanks for the reply Jonathan.

Are you in a position to share your code so I can try to reproduce on my
end?

-Bill


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

> Hello Bill,
>
> am implementing the TimestampExtractor Interface, then using it to consume,
> like:
>
> *final* KStream<..., ...> events = builder.stream(inputTopicList, Consumed.
> *with*(keySerde, valueSerde).withTimestampExtractor(*new *OwnTimeExtractor(
> ...)));
>
> Am not setting the default.timestamp.extractor config value.
>
> Cheers!
> --
> Jonathan
>
>
> On Wed, Jun 26, 2019 at 3:16 PM Bill Bejeck <bill@confluent.io> wrote:
>
> > 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
> > >
> >
>
>
> --
> Santilli Jonathan
>

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