Fix imports

mostafa · May 5, 2022 · 3e3bd84 · 3e3bd84
1 parent e33a8c2
commit 3e3bd84
Show file tree

Hide file tree

Showing 8 changed files with 8 additions and 5 deletions.
diff --git a/scripts/test_avro.js b/scripts/test_avro.js
@@ -6,7 +6,7 @@ tests Kafka with a 200 Avro messages per iteration.
 */
 
 import { check } from "k6";
-import { writer, produce, reader, consume, createTopic } from "k6/x/kafka"; // import kafka extension
+import { writer, produce, reader, consume, createTopic, deleteTopic } from "k6/x/kafka"; // import kafka extension
 
 const bootstrapServers = ["localhost:9092"];
 const kafkaTopic = "xk6_kafka_avro_topic";

diff --git a/scripts/test_avro_no_key.js b/scripts/test_avro_no_key.js
@@ -6,7 +6,7 @@ without any associated key.
 */
 
 import { check } from "k6";
-import { writer, produce, reader, consume, createTopic } from "k6/x/kafka"; // import kafka extension
+import { writer, produce, reader, consume, createTopic, deleteTopic } from "k6/x/kafka"; // import kafka extension
 
 const bootstrapServers = ["localhost:9092"];
 const kafkaTopic = "xk6_kafka_avro_topic";

diff --git a/scripts/test_avro_with_schema_registry.js b/scripts/test_avro_with_schema_registry.js
@@ -10,6 +10,7 @@ import {
     consumeWithConfiguration,
     produceWithConfiguration,
     createTopic,
+    deleteTopic,
 } from "k6/x/kafka"; // import kafka extension
 
 const bootstrapServers = ["subdomain.us-east-1.aws.confluent.cloud:9092"];

diff --git a/scripts/test_avro_with_schema_registry_no_key.js b/scripts/test_avro_with_schema_registry_no_key.js
@@ -10,6 +10,7 @@ import {
     consumeWithConfiguration,
     produceWithConfiguration,
     createTopic,
+    deleteTopic,
 } from "k6/x/kafka"; // import kafka extension
 
 const bootstrapServers = ["localhost:9092"];

diff --git a/scripts/test_bytes.js b/scripts/test_bytes.js
@@ -12,6 +12,7 @@ import {
     reader,
     consumeWithConfiguration,
     createTopic,
+    deleteTopic,
 } from "k6/x/kafka"; // import kafka extension
 
 const bootstrapServers = ["localhost:9092"];

diff --git a/scripts/test_json.js b/scripts/test_json.js
@@ -6,7 +6,7 @@ tests Kafka with a 200 JSON messages per iteration.
 */
 
 import { check } from "k6";
-import { writer, produce, reader, consume, createTopic } from "k6/x/kafka"; // import kafka extension
+import { writer, produce, reader, consume, createTopic, deleteTopic } from "k6/x/kafka"; // import kafka extension
 
 const bootstrapServers = ["localhost:9092"];
 const kafkaTopic = "xk6_kafka_json_topic";

diff --git a/scripts/test_json_with_snappy_compression.js b/scripts/test_json_with_snappy_compression.js
@@ -6,7 +6,7 @@ tests Kafka with a 200 JSON messages per iteration.
 */
 
 import { check } from "k6";
-import { writer, produce, reader, consume, createTopic } from "k6/x/kafka"; // import kafka extension
+import { writer, produce, reader, consume, createTopic, deleteTopic } from "k6/x/kafka"; // import kafka extension
 
 const bootstrapServers = ["localhost:9092"];
 const kafkaTopic = "xk6_kafka_json_snappy_topic";

diff --git a/scripts/test_topics.js b/scripts/test_topics.js
@@ -5,7 +5,7 @@ list topics on all Kafka partitions and creates a topic.
 
 */
 
-import { createTopic, listTopics } from "k6/x/kafka"; // import kafka extension
+import { createTopic, deleteTopic, listTopics } from "k6/x/kafka"; // import kafka extension
 
 const address = "localhost:9092";
 const kafkaTopic = "xk6_kafka_test_topic";