[GitHub] [kafka] urbandan commented on a diff in pull request #13475: KAFKA-14652: Add the flow to the log context and the Connect-managed …

urbandan commented on code in PR #13475: URL: https://github.com/apache/kafka/pull/13475#discussion_r1173744877 ## config/connect-mirror-maker.properties: ## @@ -57,3 +57,6 @@ config.storage.replication.factor=1 # replication.policy.separator = _ # sync.topic.acls.enabled =

[GitHub] [kafka] urbandan commented on a diff in pull request #13475: KAFKA-14652: Add the flow to the log context and the Connect-managed …

urbandan commented on code in PR #13475: URL: https://github.com/apache/kafka/pull/13475#discussion_r1153314827 ## connect/runtime/src/main/java/org/apache/kafka/connect/util/LoggingContext.java: ## @@ -181,11 +187,16 @@ public static LoggingContext forOffsets(ConnectorTaskId