jffwang
/
hetu-core
0
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

add kafka test conf

This commit is contained in:
Zhang Jianming 2022-06-23 20:30:27 +08:00
parent 7da529ee2b
commit ca4d024b24
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
presto-kafka/src/test/java/io/prestosql/plugin/kafka/TestKafkaConnectorConfig.java
View File

@ -52,12 +52,12 @@ public class TestKafkaConnectorConfig
.put("kafka.buffer-size", "1MB")
.put("kafka.hide-internal-columns", "false")
.put("group.id", "test")
.put("java.security.auth.login.config","/etc/kafka_client_jaas.conf")
.put("java.security.krb5.conf","/etc/krb5.conf")
.put("kerberos.on","false")
.put("sasl.kerberos.service.name","kafka")
.put("sasl.mechanism","GSSAPI")
.put("security.protocol","SASL_PLAINTEXT")
.put("java.security.auth.login.config", "/etc/kafka_client_jaas.conf")
.put("java.security.krb5.conf", "/etc/krb5.conf")
.put("kerberos.on", "false")
.put("sasl.kerberos.service.name", "kafka")
.put("sasl.mechanism", "GSSAPI")
.put("security.protocol", "SASL_PLAINTEXT")
.build();
KafkaConnectorConfig expected = new KafkaConnectorConfig()