New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
KAFKA-14838: Add flow/connector/task/role information to MM2 Kafka cl… #13458
Conversation
@viktorsomogyi @C0urante @mimaison You had some changes/review in this part of the code lately, could you please review? |
Hey @urbandan, it's looking like this week is going to be pretty busy for me so I may not be able to take a look immediately. I can try to take a look next week if this still hasn't received a review by then. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Turns out I'm going to be taking next week off, so I'm doing a round today and will try to be responsive for the rest of the week. Finished a complete pass; let me know if you have any questions.
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
Outdated
Show resolved
Hide resolved
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatConnector.java
Outdated
Show resolved
Hide resolved
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java
Outdated
Show resolved
Hide resolved
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java
Show resolved
Hide resolved
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java
Outdated
Show resolved
Hide resolved
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceTask.java
Outdated
Show resolved
Hide resolved
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java
Outdated
Show resolved
Hide resolved
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java
Outdated
Show resolved
Hide resolved
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java
Outdated
Show resolved
Hide resolved
...ct/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
Outdated
Show resolved
Hide resolved
@C0urante Thank you for the review, addressed your comments |
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java
Outdated
Show resolved
Hide resolved
...ct/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
Outdated
Show resolved
Hide resolved
4121411
to
d0e8960
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, thanks @urbandan!
@C0urante Thank you for the review! |
…ient.id configs
More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.
Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected for any behaviour change and
system tests should be considered for larger changes.
Committer Checklist (excluded from commit message)