[KAFKA-7634] Punctuate not being called with merge() and/or outerJoin()

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 0.11.0.3
• Component/s: streams
• Assignee: Unassigned
• Reporter: Eugen Feller
• Created: 16/Nov/18 01:29
• Updated: 10/Dec/18 05:42

Description

Hi all,

I am using the Processor API and having trouble to get Kafka streams v0.11.0.3 call the punctuate() function after a merge() and/or outerJoin(). Specifically, I am having a topology where I am doing flatMapValues() -> merge() and/or outerJoin -> transform(). If I dont call merge() and/or outerJoin() before transform(), punctuate is being called as expected.

Thank you very much in advance for your help.