From 83068a6400773d2683fa08691334178cfabd4071 Mon Sep 17 00:00:00 2001 From: joker1007 Date: Thu, 18 Apr 2024 20:25:28 +0900 Subject: [PATCH] Add SourceDynamicDefaultBroker as a type to refuse to retrieve topic settings --- kafka/topic.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/kafka/topic.go b/kafka/topic.go index 0865e698..d4712008 100644 --- 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 {