You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Sebastian Bruckner (Jira)" <ji...@apache.org> on 2022/10/06 09:22:00 UTC

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

Sebastian Bruckner created KAFKA-14282:
------------------------------------------

             Summary: 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


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