kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ted Yu <yuzhih...@gmail.com>
Subject Re: [DISCUSS] KIP-233: Simplify StreamsBuilder#addGlobalStore
Date Mon, 04 Dec 2017 18:49:48 GMT
Looks like you're implying logic similar to this:

    public synchronized <K, V> GlobalKTable<K, V> globalTable(final String
topic,

                                                              final
Consumed<K, V> consumed) {


StreamsBuilder is returned instead of GlobalKTable.


Can you add code snippet showing how the new API is used ?


On Mon, Dec 4, 2017 at 10:09 AM, Panuwat Anawatmongkhon <
panuwat.anawatmongkhon@gmail.com> wrote:

> What i am thinking right now is using the same approach as
> org.apache.kafka.streams.kstream.internals.InternalStreamsBuilder#
> globalTable
>
> On Mon, 4 Dec 2560 at 23:10 Ted Yu <yuzhihong@gmail.com> wrote:
>
> > Can you describe how sourceName is inferred based on the new API ?
> >
> > Please fill out JIRA number.
> >
> > BTW here is the URL for the KIP:
> >
> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-233%3A+Simplify+
> StreamsBuilder%23addGlobalStore
> >
> > On Mon, Dec 4, 2017 at 7:39 AM, Panuwat Anawatmongkhon <
> > panuwat.anawatmongkhon@gmail.com> wrote:
> >
> > > Hi all,
> > > I created a KIP.
> > > https://cwiki.apache.org/confluence/display/KAFKA/KIP233%3A+Simplify+
> > > StreamsBuilder%23addGlobalStore
> > >
> > > Cheers,
> > > Benz
> > >
> >
>

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