Skip to content
代码片段 群组 项目
未验证 提交 b8410a4d 编辑于 作者: Ron Dagostino's avatar Ron Dagostino 提交者: GitHub
浏览文件

MINOR: Fix failing test due to KAFKA-10556 PR (#9372)

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>, Rajini Sivaram <rajinisivaram@googlemail.com>
上级 06a5a68a
No related branches found
No related tags found
无相关合并请求
......@@ -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,
......
0% 加载中 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册