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 <yuzhih...@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.anawatmongk...@gmail.com> wrote: > > > Hi all, > > I created a KIP. > > https://cwiki.apache.org/confluence/display/KAFKA/KIP233%3A+Simplify+ > > StreamsBuilder%23addGlobalStore > > > > Cheers, > > Benz > > >
