Yeah, that should probably be changed. It is not "source" vs "sink", but rather a shortened name of the connector class. I'm actually not convinced this adds much value in the log compared to the connector name, and I've thought about removing it altogether to simplify things.
The only reason I've kept it is because one could then easily filter the log to get all logs associated with a type of connector. Is that really useful? [ Full content available at: https://github.com/apache/kafka/pull/5743 ] This message was relayed via gitbox.apache.org for [email protected]
