[kafka] branch trunk updated: MINOR: add default-replication-factor to MockAdminClient (#11648)

[mjsax]

This is an automated email from the ASF dual-hosted git repository.

mjsax 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 daaa9df  MINOR: add default-replication-factor to MockAdminClient 
(#11648)
daaa9df is described below

commit daaa9dfb54b86ccb93cc2018b374476dcb0beed1
Author: Matthias J. Sax <matth...@confluent.io>
AuthorDate: Wed Jan 5 10:37:23 2022 -0800

    MINOR: add default-replication-factor to MockAdminClient (#11648)
    
    Reviewers: Bill Bejeck <b...@confluent.io>
---
 .../src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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 473edae..1593b63 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
@@ -187,7 +187,9 @@ public class MockAdminClient extends AdminClient {
         this.brokerLogDirs = brokerLogDirs;
         this.brokerConfigs = new ArrayList<>();
         for (int i = 0; i < brokers.size(); i++) {
-            this.brokerConfigs.add(new HashMap<>());
+            final Map<String, String> config = new HashMap<>();
+            config.put("default.replication.factor", 
String.valueOf(defaultReplicationFactor));
+            this.brokerConfigs.add(config);
         }
         this.beginningOffsets = new HashMap<>();
         this.endOffsets = new HashMap<>();