Fix Previous Commit

garyrussell · garyrussell · commit 85061a4d225d · 2022-06-23T11:49:56.000-04:00
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/core/KafkaAdmin.java b/spring-kafka/src/main/java/org/springframework/kafka/core/KafkaAdmin.java
@@ -271,7 +271,7 @@ private void addOrModifyTopicsIfNeeded(AdminClient adminClient, Collection<NewTo
 				List<NewTopic> toCheck = new LinkedList<>(topics);
 				toCheck.removeAll(topicsToAdd);
 				Map<ConfigResource, List<ConfigEntry>> mismatchingConfigs =
-						checkTopicsForConfigMismatches(adminClient, topics);
+						checkTopicsForConfigMismatches(adminClient, toCheck);
 				if (!mismatchingConfigs.isEmpty()) {
 					adjustConfigMismatches(adminClient, topics, mismatchingConfigs);
 				}

Original file line number	Diff line number	Diff line change
`@@ -271,7 +271,7 @@ private void addOrModifyTopicsIfNeeded(AdminClient adminClient, Collection<NewTo`
`271`	`271`	`List<NewTopic> toCheck = new LinkedList<>(topics);`
`272`	`272`	`toCheck.removeAll(topicsToAdd);`
`273`	`273`	`Map<ConfigResource, List<ConfigEntry>> mismatchingConfigs =`
`274`		`- checkTopicsForConfigMismatches(adminClient, topics);`
	`274`	`+ checkTopicsForConfigMismatches(adminClient, toCheck);`
`275`	`275`	`if (!mismatchingConfigs.isEmpty()) {`
`276`	`276`	`adjustConfigMismatches(adminClient, topics, mismatchingConfigs);`
`277`	`277`	`}`