rException
> >
> >
> > You propose to add `otherValueSerde(final String joinName)` -- I guess
> > the method name is a c&p error and method name must be updated?
> >
> > Changes to internal classes like `KStreamImpl` are not required in the
> > KIP as th
IP doesn't outline what would happen if you
> > picked a name that resulted in a non unique topic name? What would be the
> > error handling behavior there?
> >
> > On Wed, Nov 29, 2017 at 9:03 AM Matthias Margush <
> matthias.marg...@gmail.com>
> > w
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.
Hi everyone,
I created this KIP to allow windowing joins to be named. If named, then the
associated internal topic names would be derived from that, instead of
being randomly generated.
https://cwiki.apache.org/confluence/display/KAFKA/KIP+230%3A+Name+Windowing+Joins
Thanks,
Matthias
Hi,
Can I be set up with access to author a KIP (
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals)?
My ID is matthias.margush.
Thanks,
Matthias
--
*Matthias Margush*
*matthias.marg...@fundingcircle.com * |
415.813.5245 (d) | 415.236.2884. (m)
747 Front St, 4th
