You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Kevin Perera <kp...@ippon.fr> on 2019/08/06 14:21:07 UTC
Configuring the following properties in confluent cloud
Hello! I'm trying to set up confluent cloud and publish using a java
program. According to confluent, I need to set the following parms:
Though, is there a way to configure these properties with a Java producer?
I can set the bootstrap servers well enough, but I'm struggling to
implement these other parameters. Any help is appreciated. Thank you!
ssl.endpoint.identification.algorithm=https
sasl.mechanism=PLAIN
request.timeout.ms=20000
bootstrap.servers=***
retry.backoff.ms=500
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule
required username="******" password="******";
security.protocol=SASL_SSL
Re: Configuring the following properties in confluent cloud
Posted by Martin Gainty <mg...@hotmail.com>.
in the producer initialisation code set via System.setProperty e.g.
________________________________
From: Kevin Perera <kp...@ippon.fr>
Sent: Tuesday, August 6, 2019 10:21 AM
To: users@kafka.apache.org <us...@kafka.apache.org>
Subject: Configuring the following properties in confluent cloud
Hello! I'm trying to set up confluent cloud and publish using a java
program. According to confluent, I need to set the following parms:
Though, is there a way to configure these properties with a Java producer?
I can set the bootstrap servers well enough, but I'm struggling to
implement these other parameters. Any help is appreciated. Thank you!
ssl.endpoint.identification.algorithm=https
sasl.mechanism=PLAIN
request.timeout.ms=20000
bootstrap.servers=***
retry.backoff.ms=500
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule
required username="******" password="******";
security.protocol=SASL_SSL
Re: Configuring the following properties in confluent cloud
Posted by Martin Gainty <mg...@hotmail.com>.
kevin-
in the producer initialisation code you can set SSL properties via System.setProperty
System.setProperty("java.protocol.handler.pkgs","com.sun.net.ssl.internal.www.protocol");
Security.addProvider(new com.sun.net.ssl.internal.ssl.Provider());
// uncomment the following code to turn on the trace for SSL
// System.setProperty("javax.net.debug","all");
?does this not work for you?
*bon chance*
________________________________
From: Kevin Perera <kp...@ippon.fr>
Sent: Tuesday, August 6, 2019 10:21 AM
To: users@kafka.apache.org <us...@kafka.apache.org>
Subject: Configuring the following properties in confluent cloud
Hello! I'm trying to set up confluent cloud and publish using a java
program. According to confluent, I need to set the following parms:
Though, is there a way to configure these properties with a Java producer?
I can set the bootstrap servers well enough, but I'm struggling to
implement these other parameters. Any help is appreciated. Thank you!
ssl.endpoint.identification.algorithm=https
sasl.mechanism=PLAIN
request.timeout.ms=20000
bootstrap.servers=***
retry.backoff.ms=500
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule
required username="******" password="******";
security.protocol=SASL_SSL