From 8619a973b1794d864dce930d6aaf09d2dcdb8151 Mon Sep 17 00:00:00 2001 From: Guillem Date: Wed, 12 Jun 2024 18:12:48 +0200 Subject: [PATCH] fix failing test --- destination/config_test.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/destination/config_test.go b/destination/config_test.go index 81bbe40..fde7e49 100644 --- 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, "")