[KAFKA-14282] RecordCollector throws exception on message processing

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.3.1
• Fix Version/s: 3.4.0, 3.3.2
• Component/s: streams
• Assignee: A. Sophie Blee-Goldman
• Reporter: Sebastian Bruckner
• Created: 06/Oct/22 09:21
• Updated: 12/Nov/22 02:22
• Resolved: 12/Nov/22 01:59

Description

Since we upgrade from version 3.2.0 to 3.3.1 we see a lot of exceptions thrown by the RecordCollector

stream-thread [XXX-StreamThread-1] task [2_8] Unable to records bytes produced to topic XXX by sink node KSTREAM-SINK-0000000033 as the node is not recognized.
Known sink nodes are [KSTREAM-SINK-0000000057, XXX-joined-fk-subscription-registration-sink]. 

Restarting the application did not help.

I think this is related to KIP-846 which was introduced in 3.3.0 with the ticket https://issues.apache.org/jira/browse/KAFKA-13945 .

Issue Links

• links to: GitHub Pull Request #12836