MINOR: Fix failing test due to PR
Reviewers: Chia-Ping Tsai Rajini Sivaram
@@ -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,
