Skip to content

Instantly share code, notes, and snippets.

@gAmUssA
Last active March 10, 2018 00:01
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 gAmUssA/9a5d714a9c5477d72e2ac9596032d070 to your computer and use it in GitHub Desktop.
Save gAmUssA/9a5d714a9c5477d72e2ac9596032d070 to your computer and use it in GitHub Desktop.
Do you want to use #KSQL with #ConfluentCloud https://confluent.cloud? Here's how πŸ‘‡πŸ‘‡πŸ‘‡
# a comma separated list of the the ccloud broker endpoints. e.g.
bootstrap.servers=r0.great-app.confluent.aws.prod.cloud:9092,r1.great-app.confluent.aws.prod.cloud:9093,r2.great-app.confluent.aws.prod.cloud:9094
ksql.sink.replicas=3
replication.factor=3
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=\
org.apache.kafka.common.security.plain.PlainLoginModule required \
username="<confluent cloud access key>" \
password="<confluent cloud secret>";
# Some other parameters for more reliable operation of KSQL in CP 4.1:
producer.retries=2147483647
producer.confluent.batch.expiry.ms=9223372036854775807
producer.request.timeout.ms=900000
producer.max.block.ms=900000
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment