diff --git a/examples/quickstart-confluent-cloud/README.md b/examples/quickstart-confluent-cloud/README.md index e8f9ca94..20daa29e 100644 --- a/examples/quickstart-confluent-cloud/README.md +++ b/examples/quickstart-confluent-cloud/README.md @@ -6,7 +6,7 @@ The [docker-compose.yml](docker-compose.yml) file has been revised to realize th - Removal of the _broker_ service, because replaced by the remote Kafka cluster. - _kafka-connector_: - - Definition of new environment variables to configure the remote endpoint and credentials in the `adapters.xml` trough the _variable-expansion_ feature of Lightstreamer. + - Definition of new environment variables to configure the remote endpoint, credentials, and topic name in the `adapters.xml` through the _variable-expansion__ feature of Lightstreamer. ```yaml ... environment: @@ -35,25 +35,34 @@ The [docker-compose.yml](docker-compose.yml) file has been revised to realize th $env.api_key $env.secret ``` -- _producer_: - Provisioning of the `producer.properties` configuration file to enable `SASL/PLAN` over TLS, with username and password retrieved from the environment variables `api_key` and `secret`: + **NOTE** This example assumes that the topic name is `topic_0` (the default topic provided by Confluent Cloud). If required, update the topic mapping setting by replacing `` with the appropriate value, as follows (because variable-expansion is not available in the `name` attribute): + + ```xml + item-template.stock + ``` + +- _producer_: + - Parameter `--boostrap-servers` retrieved from the environment variable `bootstrap_server`. + - Provisioning of the `producer.properties` configuration file to enable `SASL/PLAN` over TLS, with username and password retrieved from the environment variables `api_key` and `secret`: - ```yaml - # Configure SASL/PLAIN mechanism - sasl.mechanism=PLAIN - # Enable SSL encryption - security.protocol=SASL_SSL - # JAAS configuration - sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${api_key}" password="${secret}"; - ``` + ```yaml + # Configure SASL/PLAIN mechanism + sasl.mechanism=PLAIN + # Enable SSL encryption + security.protocol=SASL_SSL + # JAAS configuration + sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="${api_key}" password="${secret}"; + ``` + + **NOTE** If required, update the parameter `--topic` in the `command` attribute with the appropriate value. ## Run From this directory, run follow the command: ```sh -api_key= secret= bootstrap_server= ./start.sh +api_key= secret= bootstrap_server= topic= ./start.sh ``` where diff --git a/examples/quickstart-confluent-cloud/adapters.xml b/examples/quickstart-confluent-cloud/adapters.xml index f509ef25..2c6cec31 100644 --- a/examples/quickstart-confluent-cloud/adapters.xml +++ b/examples/quickstart-confluent-cloud/adapters.xml @@ -9,9 +9,7 @@ com.lightstreamer.kafka_connector.adapters.KafkaConnectorDataAdapter - $env.bootstrap_server - quick-start-group diff --git a/examples/quickstart-confluent-cloud/docker-compose.yml b/examples/quickstart-confluent-cloud/docker-compose.yml index 71a8b05a..561cfa2a 100644 --- a/examples/quickstart-confluent-cloud/docker-compose.yml +++ b/examples/quickstart-confluent-cloud/docker-compose.yml @@ -5,7 +5,6 @@ services: container_name: kafka-connector image: lightstreamer-kafka-connector-${version} depends_on: - - broker - producer ports: - 8080:8080 @@ -19,8 +18,6 @@ services: producer: container_name: producer - depends_on: - - broker build: context: ../compose-templates dockerfile: Dockerfile.producer diff --git a/examples/quickstart-schema-registry/README.md b/examples/quickstart-schema-registry/README.md index 04270040..9b012610 100644 --- a/examples/quickstart-schema-registry/README.md +++ b/examples/quickstart-schema-registry/README.md @@ -33,20 +33,20 @@ The [docker-compose.yml](docker-compose.yml) file has been revised to configure Extension of the `producer.properties` configuration file with the settings required to communicate with the Schema Registry: - ```yaml - ... - # JSON deserializer with support for the Schema Registry - value.serializer=io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializer - # Schema Registry URL - schema.registry.url=https://schema-registry:8084 - # Truststore configuration to authenticate the Schema Registry - schema.registry.ssl.truststore.location=/usr/app/secrets/producer.truststore.jks - schema.registry.ssl.truststore.password=producer-truststore-password - # Keystore configuration for client authentication with the Schema Registry - schema.registry.ssl.keystore.location=/usr/app/secrets/producer.keystore.jks - schema.registry.ssl.keystore.password=producer-password - schema.registry.ssl.key.password=producer-password - ``` + ```yaml + ... + # JSON deserializer with support for the Schema Registry + value.serializer=io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializer + # Schema Registry URL + schema.registry.url=https://schema-registry:8084 + # Truststore configuration to authenticate the Schema Registry + schema.registry.ssl.truststore.location=/usr/app/secrets/producer.truststore.jks + schema.registry.ssl.truststore.password=producer-truststore-password + # Keystore configuration for client authentication with the Schema Registry + schema.registry.ssl.keystore.location=/usr/app/secrets/producer.keystore.jks + schema.registry.ssl.keystore.password=producer-password + schema.registry.ssl.key.password=producer-password + ``` In addition, the `schema-registry` service references the local [`secrets/schema-registry`](../compose-templates/secrets/schema-registry/) folder to retrieve its secrets: diff --git a/examples/quickstart-ssl/README.md b/examples/quickstart-ssl/README.md index b1ab8060..8993148c 100644 --- a/examples/quickstart-ssl/README.md +++ b/examples/quickstart-ssl/README.md @@ -39,7 +39,7 @@ The [docker-compose.yml](docker-compose.yml) file has been revised to enable sup kafka-connector-password ``` - _producer_: - - New SSL endpoint (`broker:29094`). + - Parameter `--bootstrap-servers` set to the new SSL endpoint (`broker:29094`). - Provisioning of the `producer.properties` configuration file to enable SSL support: ```yaml # Enable SSL