Test config & partition update

Mongey · Mar 9, 2018 · 22f774f · 22f774f
1 parent 0b6c7c8
commit 22f774f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/kafka/resource_kafka_topic_test.go b/kafka/resource_kafka_topic_test.go
@@ -118,6 +118,10 @@ func testResourceTopic_updatePartitionsCheck(s *terraform.State) error {
 	if topic.Partitions != 2 {
 		return fmt.Errorf("partitions did not get increated got: %d", topic.Partitions)
 	}
+
+	if v, ok := topic.Config["segment.ms"]; ok && *v != "33333" {
+		return fmt.Errorf("segment.ms !=  %v", topic)
+	}
 	return nil
 }
 
@@ -167,7 +171,7 @@ resource "kafka_topic" "test" {
 
   config = {
     "retention.ms" = "11111"
-    "segment.ms" = "22222"
+    "segment.ms" = "33333"
   }
 }
 `