Hi,
I am new to the Kafka Streams framework. I have the following streams use case:
State store A
State store B
Processor A
Processor B
State store A is only written to by Processor A but also needs to be read by
Processor B. State store B needs to be written to by both Processor A and
Proces
rocessor for this.
-Matthias
On 7/17/18 11:12 PM, Druhin Sagar Goel wrote:
> Hi,
>
> I am new to the Kafka Streams framework. I have the following streams use
> case:
>
> State store A
> State store B
>
> Processor A
> Processor B
>
> State store A is only wri
Hi,
I’m using the org.kafka.streams.scala that was released with version 2.0.0. I’m
getting a StackOverflowError as follows:
java.lang.StackOverflowError
at org.apache.kafka.streams.scala.kstream.KTable.filter(KTable.scala:49)
at org.apache.kafka.streams.scala.kstream.KTable.filter(KTable.scala:
e from
filter():
implicit def wrapKTable[K, V](inner: KTableJ[K, V]): KTable[K, V] =
leading to stack overflow.
Cheers
On Mon, Aug 20, 2018 at 12:50 PM Druhin Sagar Goel
wrote:
> Hi,
>
> I’m using the org.kafka.streams.scala that was released with version
> 2.0.0. I’m getting a Sta
tion
> to StreamToTableJoinScalaIntegrationTestImplicitSerdes.scala
> I have logged KAFKA-7316 and am looking for a fix.
>
> FYI
>
> On Mon, Aug 20, 2018 at 1:39 PM Druhin Sagar Goel wrote:
>
>> Isn’t that a bug then? Or can I fix my code somehow?
>>
>>
>>
>> On August 20, 2018 at 1:30:42
