From 663dd21180a052390bc8ef03a5c57a8a575c6e83 Mon Sep 17 00:00:00 2001 From: Gianluca Date: Wed, 21 Aug 2024 11:38:32 +0200 Subject: [PATCH] Fix typos --- examples/airport-demo/connector/adapters.xml | 2 +- examples/docker-kafka-connect/README.md | 4 ++-- .../connect-standalone-docker.properties | 2 +- .../quickstart-lightstreamer-docker.properties | 6 +++--- .../quickstart-lightstreamer-local.properties | 6 +++--- kafka-connector-project/gradle.properties | 2 +- .../kafka-connector/src/adapter/dist/README.md | 2 +- .../kafka/connect/proxy/ProxyAdapterClient.java | 2 +- .../connect/config/LightstreamerConnectorConfigTest.java | 2 +- 9 files changed, 14 insertions(+), 14 deletions(-) diff --git a/examples/airport-demo/connector/adapters.xml b/examples/airport-demo/connector/adapters.xml index eb4471a7..6477ce26 100644 --- a/examples/airport-demo/connector/adapters.xml +++ b/examples/airport-demo/connector/adapters.xml @@ -52,7 +52,7 @@ - flights-#{key=KEY} diff --git a/examples/docker-kafka-connect/README.md b/examples/docker-kafka-connect/README.md index c805509a..5a34ebff 100644 --- a/examples/docker-kafka-connect/README.md +++ b/examples/docker-kafka-connect/README.md @@ -27,10 +27,10 @@ The image is based on the official [Official Confluent Docker Base Image for Kaf 3. Check that the image has been created: ```sh - $ docker image ls kafka-connect-lighstreamer- + $ docker image ls kafka-connect-lightstreamer- REPOSITORY TAG IMAGE ID CREATED SIZE - kafka-connect-lighstreamer-1.0.0 latest 417d099deaa8 18 seconds ago 1.75GB + kafka-connect-lightstreamer-1.0.0 latest 417d099deaa8 18 seconds ago 1.75GB ``` ## Running in Docker Compose diff --git a/kafka-connector-project/config/kafka-connect-config/connect-standalone-docker.properties b/kafka-connector-project/config/kafka-connect-config/connect-standalone-docker.properties index 6bc43748..d3bb7732 100644 --- a/kafka-connector-project/config/kafka-connect-config/connect-standalone-docker.properties +++ b/kafka-connector-project/config/kafka-connect-config/connect-standalone-docker.properties @@ -12,6 +12,6 @@ value.converter.schema.registry.url=http://schema-registry:8081 # The storage file name for connector offsets. offset.storage.file.filename=/tmp/connect.offsets -# The Kafka Connect Lighstreamer Sink Connector docker image installs +# The Kafka Connect Lightstreamer Sink Connector docker image installs # the connector plugins into this path plugin.path=/usr/local/share/kafka/plugins/ diff --git a/kafka-connector-project/config/kafka-connect-config/quickstart-lightstreamer-docker.properties b/kafka-connector-project/config/kafka-connect-config/quickstart-lightstreamer-docker.properties index 9ede0899..c526f450 100644 --- a/kafka-connector-project/config/kafka-connect-config/quickstart-lightstreamer-docker.properties +++ b/kafka-connector-project/config/kafka-connect-config/quickstart-lightstreamer-docker.properties @@ -26,19 +26,19 @@ topics=stocks lightstreamer.server.proxy_adapter.address=lightstreamer:6661 # The (optional) amount of time in milliseconds the connctor will wait for the socket connection -# to be established to the Lighstreamer server's Proxy Adapter before terminating the task. +# to be established to the Lightstreamer server's Proxy Adapter before terminating the task. # Specify `0` for infinite timeout. # # See https://github.com/Lightstreamer/Lightstreamer-kafka-connector/?tab=readme-ov-file#lightstreamerserverproxy_adaptersocketconnectionsetuptimeoutms lightstreamer.server.proxy_adapter.socket.connection.setup.timeout.ms=15000 -# The (optional) max number of retries to establish a connection to the Lighstreamer server's Proxy Adapter. +# The (optional) max number of retries to establish a connection to the Lightstreamer server's Proxy Adapter. # # See https://github.com/Lightstreamer/Lightstreamer-kafka-connector/?tab=readme-ov-file#ightstreamerserverproxy_adaptersocketconnectionsetupmaxretries lightstreamer.server.proxy_adapter.socket.connection.setup.max.retries=5 # The (optional) amount of time in milliseconds to wait before retrying to establish a new connection to the -# Lighstreamer server's Proxy Adapter in case of failure. +# Lightstreamer server's Proxy Adapter in case of failure. # Only applicable if `lightstreamer.server.proxy_adapter.socket.connection.setup.max.retries` > 0. # # See https://github.com/Lightstreamer/Lightstreamer-kafka-connector/?tab=readme-ov-file#lightstreamerserverproxy_adaptersocketconnectionsetupretrydelayms diff --git a/kafka-connector-project/config/kafka-connect-config/quickstart-lightstreamer-local.properties b/kafka-connector-project/config/kafka-connect-config/quickstart-lightstreamer-local.properties index 521fec49..9354ea87 100644 --- a/kafka-connector-project/config/kafka-connect-config/quickstart-lightstreamer-local.properties +++ b/kafka-connector-project/config/kafka-connect-config/quickstart-lightstreamer-local.properties @@ -26,19 +26,19 @@ topics=stocks lightstreamer.server.proxy_adapter.address=localhost:6661 # The (optional) amount of time in milliseconds the connctor will wait for the socket connection -# to be established to the Lighstreamer server's Proxy Adapter before terminating the task. +# to be established to the Lightstreamer server's Proxy Adapter before terminating the task. # Specify `0` for infinite timeout. # # See https://github.com/Lightstreamer/Lightstreamer-kafka-connector/?tab=readme-ov-file#lightstreamerserverproxy_adaptersocketconnectionsetuptimeoutms lightstreamer.server.proxy_adapter.socket.connection.setup.timeout.ms=15000 -# The (optional) max number of retries to establish a connection to the Lighstreamer server's Proxy Adapter. +# The (optional) max number of retries to establish a connection to the Lightstreamer server's Proxy Adapter. # # See https://github.com/Lightstreamer/Lightstreamer-kafka-connector/?tab=readme-ov-file#ightstreamerserverproxy_adaptersocketconnectionsetupmaxretries lightstreamer.server.proxy_adapter.socket.connection.setup.max.retries=5 # The (optional) amount of time in milliseconds to wait before retrying to establish a new connection to the -# Lighstreamer server's Proxy Adapter in case of failure. +# Lightstreamer server's Proxy Adapter in case of failure. # Only applicable if `lightstreamer.server.proxy_adapter.socket.connection.setup.max.retries` > 0. # # See https://github.com/Lightstreamer/Lightstreamer-kafka-connector/?tab=readme-ov-file#lightstreamerserverproxy_adaptersocketconnectionsetupretrydelayms diff --git a/kafka-connector-project/gradle.properties b/kafka-connector-project/gradle.properties index cb55f563..f66c8521 100644 --- a/kafka-connector-project/gradle.properties +++ b/kafka-connector-project/gradle.properties @@ -1,5 +1,5 @@ version=1.0.0 -brandedProjectName=Lighstreamer Kafka Connector +brandedProjectName=Lightstreamer Kafka Connector release_date=2024-08-19 distDir=../dist connect_owner=lightstreamer diff --git a/kafka-connector-project/kafka-connector/src/adapter/dist/README.md b/kafka-connector-project/kafka-connector/src/adapter/dist/README.md index 7cd12c9c..a4c22c9c 100644 --- a/kafka-connector-project/kafka-connector/src/adapter/dist/README.md +++ b/kafka-connector-project/kafka-connector/src/adapter/dist/README.md @@ -1,4 +1,4 @@ -# Lighstreamer Kafka Connector +# Lightstreamer Kafka Connector _Lightstreamer Kafka Connector_ is a ready-made pluggable Lightstreamer Adapter that enables event streaming from a Kafka broker to the internet. diff --git a/kafka-connector-project/kafka-connector/src/main/java/com/lightstreamer/kafka/connect/proxy/ProxyAdapterClient.java b/kafka-connector-project/kafka-connector/src/main/java/com/lightstreamer/kafka/connect/proxy/ProxyAdapterClient.java index 7d84362c..c0cfc400 100644 --- a/kafka-connector-project/kafka-connector/src/main/java/com/lightstreamer/kafka/connect/proxy/ProxyAdapterClient.java +++ b/kafka-connector-project/kafka-connector/src/main/java/com/lightstreamer/kafka/connect/proxy/ProxyAdapterClient.java @@ -47,7 +47,7 @@ public ProxyAdapterClient(ProxyAdapterClientOptions options) { public void start(DataProvider provider) throws RemotingException { logger.info( - "Starting connection with Lighstreamer'server Proxy Adapter at {}:{}", + "Starting connection with Lightstreamer'server Proxy Adapter at {}:{}", options.hostname, options.port); dataProviderServer = new DataProviderServer(); diff --git a/kafka-connector-project/kafka-connector/src/test/java/com/lightstreamer/kafka/connect/config/LightstreamerConnectorConfigTest.java b/kafka-connector-project/kafka-connector/src/test/java/com/lightstreamer/kafka/connect/config/LightstreamerConnectorConfigTest.java index fa083aef..2de7f58a 100644 --- a/kafka-connector-project/kafka-connector/src/test/java/com/lightstreamer/kafka/connect/config/LightstreamerConnectorConfigTest.java +++ b/kafka-connector-project/kafka-connector/src/test/java/com/lightstreamer/kafka/connect/config/LightstreamerConnectorConfigTest.java @@ -68,7 +68,7 @@ void shouldConfigWithRequiredParameters() { // Put valid address and go on checking props.put( LightstreamerConnectorConfig.LIGHTSTREAMER_PROXY_ADAPTER_ADDRESS, - "lighstreamer_host:6661"); + "lightstreamer_host:6661"); // No topic.mappings ce = assertThrows(ConfigException.class, () -> new LightstreamerConnectorConfig(props));