Description
The following piece of code derived from the kafka-streams/scala examples reproduces the error:
val textLines: KStream[String, String] = builder.stream[String, String]("streams-plaintext-input")
textLines.foreach((_, _) => {})
Note: the error doesn't reproduce with kafka-streams-scala_2.12.
Attachments
Issue Links
- is related to
-
KAFKA-7316 Use of filter method in KTable.scala may result in StackOverflowError
-
- Resolved
-