Hi.
I wanted to double check. If I understand the proposal, it would replace
the explicit name with a name that is dynamically generated using the
AtomicInteger index. Would this affect the naming of any internally
generated topics?
On Wed, Dec 6, 2017 at 7:59 AM Panuwat Anawatmongkhon <
panuwat.anawatmongk...@gmail.com> wrote:
> Thanks Bill.
>
> I can't think of reason to keep the old method too so if there is no
> further discussion by tomorrow, I would like to start the vote thread.
>
> On Tue, Dec 5, 2017 at 10:38 PM, Bill Bejeck <bbej...@gmail.com> wrote:
>
> > Hi Panuwat,
> >
> > Thanks for the KIP, overall looks good to me.
> >
> > I want to play the devil's advocate for a second and ask do we want to
> keep
> > the older method with the extra parameters vs. deprecation?
> >
> > Although ATM I can't think of a good reason to keep the old method with
> the
> > extra parameters.
> >
> > Thanks,
> > Bill
> >
> > On Tue, Dec 5, 2017 at 5:48 AM, Ted Yu <yuzhih...@gmail.com> wrote:
> >
> > > Fine by me.
> > >
> > > On Tue, Dec 5, 2017 at 2:45 AM, Panuwat Anawatmongkhon <
> > > panuwat.anawatmongk...@gmail.com> wrote:
> > >
> > > > Thank you, Matthias.
> > > >
> > > > Ted,
> > > > How about this.
> > > >
> > > > String globalTopicName = "testGlobalTopic";
> > > > String globalStoreName = "testAddGlobalStore";
> > > > final StreamsBuilder builder = new StreamsBuilder();
> > > > final KeyValueStoreBuilder globalStoreBuilder =
> > > > EasyMock.createNiceMock(KeyValueStoreBuilder.class);
> > > >
> EasyMock.expect(globalStoreBuilder.name()).andReturn(globalStoreName).
> > > > anyTimes();
> > > > EasyMock.replay(globalStoreBuilder);
> > > > builder.addGlobalStore(globalStoreBuilder,globalTopicName,new
> > > > ConsumedInternal(),new MockProcessorSupplier());
> > > >
> > > >
> > > >
> > > >
> > > > On Tue, Dec 5, 2017 at 4:58 AM, Matthias J. Sax <
> matth...@confluent.io
> > >
> > > > wrote:
> > > >
> > > > > Panuwat,
> > > > >
> > > > > Thanks a lot for the KIP!
> > > > >
> > > > > Just one nit: `does not follow provide a good` -> spelling: remove
> > > > > `follow` ?
> > > > >
> > > > > Otherwise, looks good to me.
> > > > >
> > > > >
> > > > > -Matthias
> > > > >
> > > > >
> > > > >
> > > > > On 12/4/17 10:49 AM, Ted Yu wrote:
> > > > > > 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.anawatmongk...@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 <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
> > > > > >>>>
> > > > > >>>
> > > > > >>
> > > > > >
> > > > >
> > > > >
> > > >
> > >
> >
>
