Connecting KSQL to Confluent CloudΒΆ

You can connect KSQL to your Confluent Platform Kafka cluster in Confluent Cloud.

The KSQL servers must be configured to use Confluent Cloud. The KSQL CLI does not require configuration.

Prerequisites

  1. Customize your /etc/ksql/ksql-server.properties properties file.

    Tip

    To use KSQL with Confluent Cloud, you must configure the KSQL server. The KSQL CLI does not require any additional configuration.

    The following example shows the minimum configuration required to use KSQL with Confluent Cloud. You should also review the recommended KSQL production settings.

    # a comma-separated list of the the ccloud broker endpoints.
    # eg. r0.great-app.confluent.aws.prod.cloud:9092,r1.great-app.confluent.aws.prod.cloud:9093,r2.great-app.confluent.aws.prod.cloud:9094
    bootstrap.servers=<broker-endpoint1, broker-endpoint2, broker-endpoint3>
    ksql.sink.replicas=3
    ksql.streams.replication.factor=3
    listeners=http://localhost:8088
    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>";
    
  2. Restart the KSQL server. The steps to restart are dependent on your environment.

For more information, see Confluent Cloud Quick Start.