We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2d9bd73 commit 64ac675Copy full SHA for 64ac675
exporter/kafkaexporter/config_test.go
@@ -294,6 +294,22 @@ func TestValidate_sasl_version(t *testing.T) {
294
assert.EqualError(t, err, "auth.sasl.version has to be either 0 or 1. configured value 42")
295
}
296
297
+func TestValidate_sasl_iam(t *testing.T) {
298
+ config := &Config{
299
+ Producer: Producer{
300
+ Compression: "none",
301
+ },
302
+ Authentication: kafka.Authentication{
303
+ SASL: &kafka.SASLConfig{
304
+ Mechanism: "AWS_MSK_IAM",
305
306
307
+ }
308
+
309
+ err := config.Validate()
310
+ assert.Equal(t, err, nil)
311
+}
312
313
func Test_saramaProducerCompressionCodec(t *testing.T) {
314
tests := map[string]struct {
315
compression string
0 commit comments