[jira] [Commented] (KAFKA-14282) RecordCollector throws exception on message processing

["A. Sophie Blee-Goldman (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-14282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629661#comment-17629661 ] 

A. Sophie Blee-Goldman commented on KAFKA-14282:
------------------------------------------------

Thanks for the report. I'll try to look into this, do you have any application logs from around the time of these exceptions that you could upload here?

> 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)