Dear community, I would like to get further feedbacks on this KIP (if any).
Cheers Jeyhun On Wed, Feb 15, 2017 at 2:36 AM Matthias J. Sax <matth...@confluent.io> wrote: > Mathieu, > > I personally agree with your observation, and we have plans to submit a > KIP like this. If you want to drive this discussion feel free to start > the KIP by yourself! > > Having said that, for this KIP we might want to focus the discussion the > the actual feature that gets added: allowing to specify different > TS-Extractor for different inputs. > > > > -Matthias > > On 2/14/17 4:54 PM, Mathieu Fenniak wrote: > > Hi Jeyhun, > > > > This KIP might not be the appropriate time, but my first thought reading > it > > is that it might make sense to introduce a builder-style API rather than > > adding a mix of new method overloads with independent optional > parameters. > > :-) > > > > eg. stream(), table(), globalTable(), addSource(), could all accept a > > "TopicReference" parameter that can be built like: > > > TopicReference("my-topic").keySerde(...).valueSerde(...).autoOffsetReset(...).timestampExtractor(...).build(). > > > > Mathieu > > > > > > On Tue, Feb 14, 2017 at 5:31 PM, Jeyhun Karimov <je.kari...@gmail.com> > > wrote: > > > >> Dear community, > >> > >> I want to share the KIP-123 [1] which is based on issue KAFKA-4144 [2]. > You > >> can check the PR in [3]. > >> > >> I would like to get your comments. > >> > >> [1] > >> > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=68714788 > >> [2] https://issues.apache.org/jira/browse/KAFKA-4144 > >> [3] https://github.com/apache/kafka/pull/2466 > >> > >> > >> Cheers, > >> Jeyhun > >> -- > >> -Cheers > >> > >> Jeyhun > >> > > > > -- -Cheers Jeyhun