ableegoldman opened a new pull request, #12836: URL: https://github.com/apache/kafka/pull/12836
Users have been seeing a large number of these error messages being logged by the RecordCollectorImpl: ``` Unable to records bytes produced to topic XXX by sink node YYY as the node is not recognized. ``` It seems like we try to save all known sink nodes when the record collector is constructed, by we do so by going through the known sink topics which means we could miss some nodes, for example if dynamic topic routing is used. Previously we were logging an error and would skip recording the metric if we tried to `send` a record from a sink node it didn't recognize, but there's not really any reason to have been tracking the sensors by node in the first place -- we can just track the actual sink topics themselves. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
