[ https://issues.apache.org/jira/browse/KAFKA-14282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sebastian Bruckner updated KAFKA-14282: --------------------------------------- Description: Since we upgrade from version 3.2.0 to 3.3.1 we see a lot of exceptions thrown by the RecordCollector {code:java} 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]. {code} Restarting the application did not help. I think this is related to [KIP-846|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211886093] which was introduced in 3.3.0 with the ticket https://issues.apache.org/jira/browse/KAFKA-13945 . was: Since we upgrade from version 3.2.0 to 3.3.1 we see a lot of exceptions thrown by the RecordCollector {code:java} 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]. {code} Restarting the application did not help. I think this is related to [KIP-846|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211886093] which was introduced in 3.3.0 with the ticket https://issues.apache.org/jira/browse/KAFKA-13945 . > RecordCollector throws exception on message processing > ------------------------------------------------------ > > Key: KAFKA-14282 > URL: https://issues.apache.org/jira/browse/KAFKA-14282 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 3.3.1 > Reporter: Sebastian Bruckner > Priority: Major > > Since we upgrade from version 3.2.0 to 3.3.1 we see a lot of exceptions > thrown by the RecordCollector > {code:java} > 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]. > {code} > Restarting the application did not help. > I think this is related to > [KIP-846|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211886093] > which was introduced in 3.3.0 with the ticket > https://issues.apache.org/jira/browse/KAFKA-13945 . -- This message was sent by Atlassian Jira (v8.20.10#820010)