[
https://issues.apache.org/jira/browse/KAFKA-14282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630184#comment-17630184
]
Ramiz Mehran commented on KAFKA-14282:
--------------------------------------
I am also facing the same. Adding logs below:
<app_name> <server-ip> 07-11-2022 19:00:31.602 [,] ERROR
org.apache.kafka.streams.processor.internals.RecordCollectorImpl: -
stream-thread [<client-id>-StreamThread-8] task [0_136] Unable to records bytes
produced to topic <topic-name> by sink node KSTREAM-SINK-0000000009 as the node
is not recognized.
Known sink nodes are [].
<app_name> <server-ip> 07-11-2022 19:00:31.602 [,] ERROR
org.apache.kafka.streams.processor.internals.RecordCollectorImpl: -
stream-thread [<client-id>-StreamThread-8] task [0_136] Unable to records bytes
produced to topic <topic-name> by sink node KSTREAM-SINK-0000000009 as the node
is not recognized.
Known sink nodes are [].
<app_name> <server-ip> 07-11-2022 19:00:31.602 [,] ERROR
org.apache.kafka.streams.processor.internals.RecordCollectorImpl: -
stream-thread [<client-id>-StreamThread-8] task [0_136] Unable to records bytes
produced to topic <topic-name> by sink node KSTREAM-SINK-0000000009 as the node
is not recognized.
Known sink nodes are [].
> 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)
