diff --git a/common/component/kafka/metadata_test.go b/common/component/kafka/metadata_test.go index e53b1721d8..acb6eb1208 100644 --- a/common/component/kafka/metadata_test.go +++ b/common/component/kafka/metadata_test.go @@ -376,20 +376,6 @@ func TestTls(t *testing.T) { }) } -func TestAwsIam(t *testing.T) { - k := getKafka() - - t.Run("missing aws region", func(t *testing.T) { - m := getBaseMetadata() - m[authType] = awsIAMAuthType - meta, err := k.getKafkaMetadata(m) - require.Error(t, err) - require.Nil(t, meta) - - require.Equal(t, "missing AWS region property 'awsRegion' for authType 'awsiam'", err.Error()) - }) -} - func TestMetadataConsumerFetchValues(t *testing.T) { k := getKafka() m := getCompleteMetadata()