Skip to content

Commit

Permalink
Fix typo in SASL_MECHANIM env var
Browse files Browse the repository at this point in the history
  • Loading branch information
jwalcorn authored Dec 6, 2023
1 parent 90b3c33 commit 6c199ca
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ public class EventStreamsProducer {
private final String topic;
private final String API_KEY = System.getenv("KAFKA_API_KEY");
private String USERNAME = System.getenv("KAFKA_USER");
private String SASL_MECHANISM = System.getenv("KMP_MESSAGING_CONNECTOR_LIBERTY_KAFKA_SASL_MECHANISM");
private String SASL_MECHANISM = System.getenv("MP_MESSAGING_CONNECTOR_LIBERTY_KAFKA_SASL_MECHANISM");
private String SASL_JAAS_CONFIG = System.getenv("MP_MESSAGING_CONNECTOR_LIBERTY_KAFKA_SASL_JAAS_CONFIG");

private KafkaProducer<String, String> kafkaProducer;
Expand Down

0 comments on commit 6c199ca

Please sign in to comment.