fix failing test

ConduitIO · Jun 12, 2024 · 8619a97 · 8619a97
1 parent 5683f8e
commit 8619a97
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/destination/config_test.go b/destination/config_test.go
@@ -98,11 +98,13 @@ func TestConfig_ParseTopic_DoesErrorOnTopicNotFound(t *testing.T) {
 	is.Equal(topic, "")
 
 	rec := sdk.Record{
+		Key: sdk.RawData("testkey"),
 		Metadata: map[string]string{
 			"topic": "testtopic",
 		},
 	}
 	topic, err = getTopic(rec)
+	is.True(err != nil)                                                 // expected error on topic not found
 	is.True(strings.Contains(err.Error(), "topic not found on record")) // expected topic not found error
 
 	is.Equal(topic, "")