Justinwins created KAFKA-14027:
----------------------------------
Summary: org.apache.kafka.connect.mirror.MirrorClient class clean
up
Key: KAFKA-14027
URL: https://issues.apache.org/jira/browse/KAFKA-14027
Project: Kafka
Issue Type: New Feature
Components: KafkaConnect
Reporter: Justinwins
1)
{code:java}
// code placeholder
public Set<String> upstreamClusters() throws InterruptedException {
return listTopics().stream()
.filter(this::isHeartbeatTopic)
.flatMap(x -> allSources(x).stream())
.distinct()
.collect(Collectors.toSet());
} {code}
no need to user `distinct()`
2) we can use try-with-resources instead of try finally for
remoteConsumerOffsets method
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
