You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2020/06/17 20:46:48 UTC
[kafka] branch trunk updated: MINOR: reuse toConfigObject(Map) to
generate Config (#8889)
This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 3b7c2ab MINOR: reuse toConfigObject(Map) to generate Config (#8889)
3b7c2ab is described below
commit 3b7c2ab6d814e7860771f2eec055d34be5002e5d
Author: Chia-Ping Tsai <ch...@gmail.com>
AuthorDate: Thu Jun 18 04:46:05 2020 +0800
MINOR: reuse toConfigObject(Map) to generate Config (#8889)
Author: Chia-Ping Tsai <ch...@gmail.com>
Reviewers: Randall Hauch <rh...@gmail.com>, David Jacot <da...@gmail.com>
---
.../test/java/org/apache/kafka/clients/admin/MockAdminClient.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java b/clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java
index 7c6a955..e5ad575 100644
--- a/clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java
+++ b/clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java
@@ -51,7 +51,6 @@ import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.Set;
-import java.util.stream.Collectors;
public class MockAdminClient extends AdminClient {
public static final String DEFAULT_CLUSTER_ID = "I4ZmrWqfT2e-upky_4fdPA";
@@ -532,9 +531,7 @@ public class MockAdminClient extends AdminClient {
if (topicMetadata != null && !topicMetadata.markedForDeletion) {
if (topicMetadata.fetchesRemainingUntilVisible > 0)
topicMetadata.fetchesRemainingUntilVisible = Math.max(0, topicMetadata.fetchesRemainingUntilVisible - 1);
- else return new Config(topicMetadata.configs.entrySet().stream()
- .map(entry -> new ConfigEntry(entry.getKey(), entry.getValue()))
- .collect(Collectors.toList()));
+ else return toConfigObject(topicMetadata.configs);
}
throw new UnknownTopicOrPartitionException("Resource " + resource + " not found.");