Jeyhun, can you please add the KIP to this table: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals#KafkaImprovementProposals-KIPsunderdiscussion
and to this list: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams Thanks! -Matthias On 2/14/17 5:36 PM, Matthias J. Sax 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 >>> >> >
signature.asc
Description: OpenPGP digital signature
