Add SourceDynamicDefaultBroker as a type to refuse to retrieve topic …

…settings
Mongey · Apr 22, 2024 · 83068a6 · 83068a6
1 parent 40dacea
commit 83068a6
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/kafka/topic.go b/kafka/topic.go
@@ -60,7 +60,9 @@ func isDefault(tc *sarama.ConfigEntry, version int) bool {
 	if version == 0 {
 		return tc.Default
 	}
-	return tc.Source == sarama.SourceDefault || tc.Source == sarama.SourceStaticBroker
+	return tc.Source == sarama.SourceDefault ||
+		tc.Source == sarama.SourceStaticBroker ||
+		tc.Source == sarama.SourceDynamicDefaultBroker
 }
 
 func metaToTopic(d *schema.ResourceData, meta interface{}) Topic {