From 961111d365e34163334fb3dbf34222ac354d8a3c Mon Sep 17 00:00:00 2001 From: sunil unnava Date: Mon, 17 Sep 2018 10:19:14 -0400 Subject: Changes for Kafka AAF integration Issue-ID: DMAAP-772 Change-Id: I60e07746c48967500f744f3fe9632d55197277bb Signed-off-by: sunil unnava --- src/test/java/com/att/nsa/cambria/embed/EmbedConfigurationReader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'src/test/java') diff --git a/src/test/java/com/att/nsa/cambria/embed/EmbedConfigurationReader.java b/src/test/java/com/att/nsa/cambria/embed/EmbedConfigurationReader.java index 30cb460..228664b 100644 --- a/src/test/java/com/att/nsa/cambria/embed/EmbedConfigurationReader.java +++ b/src/test/java/com/att/nsa/cambria/embed/EmbedConfigurationReader.java @@ -97,7 +97,7 @@ public class EmbedConfigurationReader { final Properties props = new Properties (); props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092" ); - props.put("sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required username='admin' password='admin_secret'"); + props.put("sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required username='admin' password='admin_secret'"); props.put(AdminClientConfig.SECURITY_PROTOCOL_CONFIG, "SASL_PLAINTEXT"); props.put("sasl.mechanism", "PLAIN"); fKafkaAdminClient = AdminClient.create ( props ); -- cgit 1.2.3-korg