gt; I assume no.
> >> > > > 3. Can I import the Guarded class once, e.g. in a "common" jar
> >> > > > created w/ sbt-assembly?
> >> > > > Or should I explicitly import an alternative
> >> > > > Fun
sions.{
>> > > > FlatValueMapperFromFunction,
>> > > > FlatValueMapperWithKeyFromFunction,
>> > > > ForeachActionFromFunction,
>> > > > KeyValueMapperFromFunction,
>> > > > MapperFromFunction,
>> > &
FromFunction,
> > > > ValueTransformerSupplierAsJava,
> > > > ValueTransformerSupplierWithKeyAsJava
> > > > }
> > > >
> > > >
> > > > On Sun, May 9, 2021 at 5:30 PM John Roesler
> wrote:
> > > >
> > > &
s
> > into
> > > > the library, and I think it’s a good idea, but we haven’t had anyone
> > draft
> > > > a proposal.
> > > >
> > > > My bias with Scala is actually to avoid using implicits for nontrivial
> > > > logic like th
licits for nontrivial
> > > logic like this. It’s convenient, but it also makes the code hard to
> > > understand, especially for newcomers to your codebase.
> > >
> > > If you do want to stick with implicits, I’m not sure what the problem
> > > might be.
py/paste it’s logic into your implementation.
> >
> > Note also that you will have to make sure that in your topology building
> > code, you have to import your implicit converter, and you cannot import
> > ours.
> >
> > I hope this helps!
> > -John
> >
>
u have to import your implicit converter, and you cannot import
> ours.
>
> I hope this helps!
> -John
>
> On Sun, May 9, 2021, at 02:20, Rama Eshel wrote:
> >
> https://stackoverflow.com/questions/67289232/kafkastreams-scala-replace-functionscompatconversions
> >
&g
make sure that in your topology building code,
you have to import your implicit converter, and you cannot import ours.
I hope this helps!
-John
On Sun, May 9, 2021, at 02:20, Rama Eshel wrote:
> https://stackoverflow.com/questions/67289232/kafkastreams-scala-replace-functionscompatconversi
https://stackoverflow.com/questions/67289232/kafkastreams-scala-replace-functionscompatconversions
I asked this question ~10 days ago, and it now occurs to me that I asked it
in the wrong place. So trying here:
I am using KafkaStreams 2.6.0, scala, in an existing bunch of applications.
I&#
