Hi Jeyhun,
Thanks for the KIP, sorry I'm coming a bit late to the discussion.
One thing I'd like to understand is whether we can avoid situations where the
user is mixing different times (event time vs. wallclock time) in their
processing inadvertently. Before this KIP, all the relevant topics have one
time stamp extractor so that issue does not come up.
What will be the behavior if times mismatch, e.g., for joins?
Thanks
Eno
> On 22 Feb 2017, at 09:21, Jeyhun Karimov <je.kari...@gmail.com> wrote:
>
> 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
