[KAFKA-7521] [kafka-streams-scala_2.11] Foreach results in StackOverflowError

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 2.0.0
• Fix Version/s: 2.1.0
• Component/s: streams
• Assignee: Joan Goyeau
• Reporter: Bogdan Iordache
• Created: 19/Oct/18 12:37
• Updated: 20/Oct/18 19:32
• Resolved: 20/Oct/18 19:32

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.

Issue Links

• is related to: KAFKA-7316 Use of filter method in KTable.scala may result in StackOverflowError