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
>
