Hi everyone, I would like to bump this thread. I think this would be very useful for any MM2 users, as the current logs with certain architectures (e.g. fan-out) are impossible to decipher. I already submitted a PR to demonstrate the proposed solution: https://github.com/apache/kafka/pull/13475
Thanks for your comments in advance, Daniel Dániel Urbán <urb.dani...@gmail.com> ezt írta (időpont: 2023. márc. 30., Cs, 18:24): > Hello everyone, > > I would like to kick off a discussion about KIP-916: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-916%3A+MM2+distributed+mode+flow+log+context > > The KIP aims to enhance the diagnostic information for MM2 distributed > mode. MM2 relies on multiple Connect worker instances nested in a single > process. In Connect, Connector names are guaranteed to be unique in a > single process, but in MM2, this is not true. Because of this, the > diagnostics provided by Connect (client.ids, log context) do not ensure > that logs are distinguishable for different flows (Connect workers) inside > an MM2 process. > > Thanks for all you input in advance, > Daniel >
