C0urante commented on code in PR #11779:
URL: https://github.com/apache/kafka/pull/11779#discussion_r891395016
##########
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##########
@@ -784,6 +845,14 @@ private static Map<String, Object>
connectorClientConfigOverrides(ConnectorTaskI
return clientOverrides;
}
+ private String transactionalId(ConnectorTaskId id) {
Review Comment:
Ah whoops, those changes were made on
https://github.com/apache/kafka/pull/11780, which hasn't been merged yet, so a
rebase isn't going to automatically draw them in. I'll do the change manually
here but there may be other small changes in not-yet-merged PRs that don't get
pulled in here. It should be fine as those changes are included in whichever PR
gets merged last.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
