I am not sure if this is practical or not. But theoretically a user may
want to extract the unsafe Java abstraction from the Scala ones and use
Java APIs on them .. e.g.
val userClicksStream: KStreamS[String, Long] =
builder.stream(userClicksTopic) // Scala abstraction
val jStream: KStream[String, Long] = userClicksStream.inner // publishes
the underlying Java abstraction
//.. work with Java, may be pass to some function written in Java
I do realize this is somewhat of a convoluted use case and may not be
practically useful ..
Otherwise we can very well work on the suggested approach of unifying the
names ..
regards.
On Fri, Mar 16, 2018 at 10:28 PM, Ismael Juma <ism...@juma.me.uk> wrote:
> What does "mixed mode application" mean? What are the cases where a user
> would want to use both APIs? I think that would help understand the
> reasoning.
>
> Thanks,
> Ismael
>
> On Fri, Mar 16, 2018 at 8:48 AM, Debasish Ghosh <
> debasish.gh...@lightbend.com> wrote:
>
> > Hi Damian -
> >
> > We could. But in case the user wants to use both Scala and Java APIs (may
> > be for some mixed mode application), won't that be confusing ? She will
> > have to do something like ..
> >
> > import o.a.k.s.scala.{KStream => KStreamS}
> >
> > to rename Scala imports or the other way round for imported Java classes.
> >
> > regards.
> >
> >
> >
> > On Fri, Mar 16, 2018 at 9:07 PM, Damian Guy <damian....@gmail.com>
> wrote:
> >
> > > Hi Debasish,
> > >
> > > Thanks for the KIP - will be a great addition to streams. I've only
> had a
> > > quick scan, but seeing as the Scala classes are going to be in their
> own
> > > package could we drop the S at the end of the class names?
> > >
> > > Thanks,
> > > Damian
> > >
> > >
> > > On Fri, 16 Mar 2018 at 15:25 Debasish Ghosh <
> > debasish.gh...@lightbend.com>
> > > wrote:
> > >
> > > > Hi -
> > > >
> > > > A new KIP, KIP-270 is up for discussion:
> > > >
> > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-
> > > 270+-+A+Scala+Wrapper+Library+for+Kafka+Streams
> > > >
> > > > The relevant JIRA issue: https://issues.apache.org/
> > > jira/browse/KAFKA-6670
> > > >
> > > > The library as proposed in the KIP has been implemented at
> > > > https://github.com/lightbend/kafka-streams-scala and the current
> > release
> > > > is
> > > > 0.2.0 (
> > > > https://github.com/lightbend/kafka-streams-scala/releases/tag/v0.2.0
> ).
> > > > We at Lightbend has been using it since quite some time now.
> > > >
> > > > regards.
> > > >
> > > > --
> > > > Debasish Ghosh
> > > > Principal Engineer
> > > >
> > > > Twitter: @debasishg
> > > > Blog: http://debasishg.blogspot.com
> > > > Code: https://github.com/debasishg
> > > >
> > >
> >
> >
> >
> > --
> > Debasish Ghosh
> > Principal Engineer
> >
> > Twitter: @debasishg
> > Blog: http://debasishg.blogspot.com
> > Code: https://github.com/debasishg
> >
>
--
Debasish Ghosh
Principal Engineer
Twitter: @debasishg
Blog: http://debasishg.blogspot.com
Code: https://github.com/debasishg
