Skip to content

Instantly share code, notes, and snippets.

@recursivecodes

recursivecodes/CompatibleProducer.java

Last active December 18, 2019 17:33
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save recursivecodes/d5dca022a87becdcd891ce286b296019 to your computer and use it in GitHub Desktop.
Save recursivecodes/d5dca022a87becdcd891ce286b296019 to your computer and use it in GitHub Desktop.
Download ZIP
CompatibleProducer.java
Raw
CompatibleProducer.java
Properties properties = new Properties();
properties.put("bootstrap.servers", "streaming.us-phoenix-1.oci.oraclecloud.com:9092");
properties.put("security.protocol", "SASL_SSL");
properties.put("sasl.mechanism", "PLAIN");
properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
properties.put("sasl.jaas.config",
                "org.apache.kafka.common.security.plain.PlainLoginModule required username=\""
                + tenancyName + "/"
                + username + "/"
                + streamPoolId + "\" "
                + "password=\""
                + authToken + "\";"
);
properties.put("retries", 5); // retries on transient errors and load balancing disconnection
properties.put("max.request.size", 1024 * 1024); // limit request size to 1MB
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment