From a4af57f3653e351529da6f53bd894d669cdc5c87 Mon Sep 17 00:00:00 2001 From: Ron Dagostino Date: Tue, 6 Oct 2020 04:13:35 -0400 Subject: [PATCH] MINOR: Fix failing test due to KAFKA-10556 PR (#9372) Reviewers: Chia-Ping Tsai , Rajini Sivaram --- core/src/test/scala/integration/kafka/api/MetricsTest.scala | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/core/src/test/scala/integration/kafka/api/MetricsTest.scala b/core/src/test/scala/integration/kafka/api/MetricsTest.scala index 5e92eca7afc31..6c90362049c5c 100644 --- a/core/src/test/scala/integration/kafka/api/MetricsTest.scala +++ b/core/src/test/scala/integration/kafka/api/MetricsTest.scala @@ -26,6 +26,7 @@ import org.apache.kafka.common.config.SaslConfigs import org.apache.kafka.common.errors.InvalidTopicException import org.apache.kafka.common.network.ListenerName import org.apache.kafka.common.security.auth.SecurityProtocol +import org.apache.kafka.common.security.authenticator.TestJaasConfig import org.junit.{After, Before, Test} import org.junit.Assert._ import org.scalatest.Assertions.fail @@ -113,8 +114,8 @@ class MetricsTest extends IntegrationTestHarness with SaslSetup { // Create a producer that fails authentication to verify authentication failure metrics private def generateAuthenticationFailure(tp: TopicPartition): Unit = { val saslProps = new Properties() - // Temporary limit to reduce blocking before KIP-152 client-side changes are merged - saslProps.put(SaslConfigs.SASL_MECHANISM, "SCRAM-SHA-256") + saslProps.put(SaslConfigs.SASL_MECHANISM, kafkaClientSaslMechanism) + saslProps.put(SaslConfigs.SASL_JAAS_CONFIG, TestJaasConfig.jaasConfigProperty(kafkaClientSaslMechanism, "badUser", "badPass")) // Use acks=0 to verify error metric when connection is closed without a response val producer = TestUtils.createProducer(brokerList, acks = 0,