This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit fe83945eae4b5bd6373b900e79ca78c063d82fb3 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Mon Sep 13 15:36:59 2021 +0200 Regen all --- .../ROOT/pages/aws-s3-streaming-upload-sink.adoc | 1 + .../ROOT/pages/has-header-filter-action.adoc | 1 + .../ROOT/pages/kafka-not-secured-source.adoc | 1 + docs/modules/ROOT/pages/kafka-source.adoc | 1 + docs/modules/ROOT/pages/rabbitmq-source.adoc | 21 +++++++++------------ docs/modules/ROOT/pages/telegram-source.adoc | 4 ++++ .../bindings/camel-k/rabbitmq-source-binding.yaml | 4 +--- .../bindings/core/rabbitmq-source-binding.yaml | 4 +--- 8 files changed, 19 insertions(+), 18 deletions(-) diff --git a/docs/modules/ROOT/pages/aws-s3-streaming-upload-sink.adoc b/docs/modules/ROOT/pages/aws-s3-streaming-upload-sink.adoc index 319a9cf..f316a77 100644 --- a/docs/modules/ROOT/pages/aws-s3-streaming-upload-sink.adoc +++ b/docs/modules/ROOT/pages/aws-s3-streaming-upload-sink.adoc @@ -24,6 +24,7 @@ The following table summarizes the configuration options available for the `aws- | namingStrategy| Naming Strategy| The naming strategy to use in streaming upload mode. There are 2 enums and the value can be one of progressive, random| string| `"progressive"`| | restartingPolicy| Restarting Policy| The restarting policy to use in streaming upload mode. There are 2 enums and the value can be one of override, lastPart| string| `"lastPart"`| | streamingUploadMode| Streaming Upload Mode| Setting the Streaming Upload Mode| boolean| `true`| +| streamingUploadTimeout| Streaming Upload Timeout| While streaming upload mode is true, this option set the timeout to complete upload| long| | |=== NOTE: Fields marked with ({empty}*) are mandatory. diff --git a/docs/modules/ROOT/pages/has-header-filter-action.adoc b/docs/modules/ROOT/pages/has-header-filter-action.adoc index 7cf1775..f1d2349 100644 --- a/docs/modules/ROOT/pages/has-header-filter-action.adoc +++ b/docs/modules/ROOT/pages/has-header-filter-action.adoc @@ -14,6 +14,7 @@ The following table summarizes the configuration options available for the `has- |=== | Property| Name| Description| Type| Default| Example | *name {empty}* *| Header Name| The header name to evaluate| string| | `"headerName"` +| value| Header Value| An optional header value to compare the header to| string| | `"headerValue"` |=== NOTE: Fields marked with ({empty}*) are mandatory. diff --git a/docs/modules/ROOT/pages/kafka-not-secured-source.adoc b/docs/modules/ROOT/pages/kafka-not-secured-source.adoc index c782de8..c03ed66 100644 --- a/docs/modules/ROOT/pages/kafka-not-secured-source.adoc +++ b/docs/modules/ROOT/pages/kafka-not-secured-source.adoc @@ -18,6 +18,7 @@ The following table summarizes the configuration options available for the `kafk | allowManualCommit| Allow Manual Commit| Whether to allow doing manual commits| boolean| `false`| | autoCommitEnable| Auto Commit Enable| If true, periodically commit to ZooKeeper the offset of messages already fetched by the consumer| boolean| `true`| | autoOffsetReset| Auto Offset Reset| What to do when there is no initial offset. There are 3 enums and the value can be one of latest, earliest, none| string| `"latest"`| +| consumerGroup| Consumer Group| A string that uniquely identifies the group of consumers to which this source belongs| string| | `"my-group-id"` | pollOnError| Poll On Error Behavior| What to do if kafka threw an exception while polling for new messages. There are 5 enums and the value can be one of DISCARD, ERROR_HANDLER, RECONNECT, RETRY, STOP| string| `"ERROR_HANDLER"`| |=== diff --git a/docs/modules/ROOT/pages/kafka-source.adoc b/docs/modules/ROOT/pages/kafka-source.adoc index d58652a..e1b8567 100644 --- a/docs/modules/ROOT/pages/kafka-source.adoc +++ b/docs/modules/ROOT/pages/kafka-source.adoc @@ -20,6 +20,7 @@ The following table summarizes the configuration options available for the `kafk | allowManualCommit| Allow Manual Commit| Whether to allow doing manual commits| boolean| `false`| | autoCommitEnable| Auto Commit Enable| If true, periodically commit to ZooKeeper the offset of messages already fetched by the consumer| boolean| `true`| | autoOffsetReset| Auto Offset Reset| What to do when there is no initial offset. There are 3 enums and the value can be one of latest, earliest, none| string| `"latest"`| +| consumerGroup| Consumer Group| A string that uniquely identifies the group of consumers to which this source belongs| string| | `"my-group-id"` | pollOnError| Poll On Error Behavior| What to do if kafka threw an exception while polling for new messages. There are 5 enums and the value can be one of DISCARD, ERROR_HANDLER, RECONNECT, RETRY, STOP| string| `"ERROR_HANDLER"`| | saslMechanism| SASL Mechanism| The Simple Authentication and Security Layer (SASL) Mechanism used.| string| `"PLAIN"`| | securityProtocol| Security Protocol| Protocol used to communicate with brokers. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL and SSL are supported| string| `"SASL_SSL"`| diff --git a/docs/modules/ROOT/pages/rabbitmq-source.adoc b/docs/modules/ROOT/pages/rabbitmq-source.adoc index 996a1c7..1eabb7b 100644 --- a/docs/modules/ROOT/pages/rabbitmq-source.adoc +++ b/docs/modules/ROOT/pages/rabbitmq-source.adoc @@ -13,11 +13,12 @@ The following table summarizes the configuration options available for the `rabb [width="100%",cols="2,^2,3,^2,^2,^3",options="header"] |=== | Property| Name| Description| Type| Default| Example -| *addresses {empty}* *| Addresses| Comma separated list of RabbitMQ broker addresses| string| | +| *addresses {empty}* *| Addresses| Comma separated list of RabbitMQ broker addresses| string| | `"localhost:5672"` | *exchangeName {empty}* *| Exchange name| The exchange name determines the exchange the queue will be bound to| string| | -| *password {empty}* *| Password| The password to access the RabbitMQ server| string| | -| *username {empty}* *| Username| The username to access the RabbitMQ server| string| | -| portNumber| Port Number| Port of the RabbitMQ server| string| `5672`| +| password| Password| The password to access the RabbitMQ server| string| | +| queue| Queue name| The queue to receive messages from| string| | +| routingKey| Routing Key| The routing key to use when binding a consumer queue to the exchange| string| | +| username| Username| The username to access the RabbitMQ server| string| | |=== NOTE: Fields marked with ({empty}*) are mandatory. @@ -44,10 +45,8 @@ spec: apiVersion: camel.apache.org/v1alpha1 name: rabbitmq-source properties: - addresses: "The Addresses" + addresses: "localhost:5672" exchangeName: "The Exchange name" - password: "The Password" - username: "The Username" sink: ref: kind: InMemoryChannel @@ -72,7 +71,7 @@ The procedure described above can be simplified into a single execution of the ` [source,shell] ---- -kamel bind rabbitmq-source -p "source.addresses=The Addresses" -p "source.exchangeName=The Exchange name" -p "source.password=The Password" -p "source.username=The Username" channel/mychannel +kamel bind rabbitmq-source -p "source.addresses=localhost:5672" -p "source.exchangeName=The Exchange name" channel/mychannel ---- This will create the KameletBinding under the hood and apply it to the current namespace in the cluster. @@ -95,10 +94,8 @@ spec: apiVersion: camel.apache.org/v1alpha1 name: rabbitmq-source properties: - addresses: "The Addresses" + addresses: "localhost:5672" exchangeName: "The Exchange name" - password: "The Password" - username: "The Username" sink: ref: kind: KafkaTopic @@ -125,7 +122,7 @@ The procedure described above can be simplified into a single execution of the ` [source,shell] ---- -kamel bind rabbitmq-source -p "source.addresses=The Addresses" -p "source.exchangeName=The Exchange name" -p "source.password=The Password" -p "source.username=The Username" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic +kamel bind rabbitmq-source -p "source.addresses=localhost:5672" -p "source.exchangeName=The Exchange name" kafka.strimzi.io/v1beta1:KafkaTopic:my-topic ---- This will create the KameletBinding under the hood and apply it to the current namespace in the cluster. diff --git a/docs/modules/ROOT/pages/telegram-source.adoc b/docs/modules/ROOT/pages/telegram-source.adoc index 5283d47..bfefbce 100644 --- a/docs/modules/ROOT/pages/telegram-source.adoc +++ b/docs/modules/ROOT/pages/telegram-source.adoc @@ -9,6 +9,10 @@ Receive all messages that people send to your Telegram bot. To create a bot, contact the @botfather account using the Telegram app. +The source attaches the following headers to the messages: + +- `chat-id` / `ce-chat-id`: the ID of the chat where the message comes from + == Configuration Options The following table summarizes the configuration options available for the `telegram-source` Kamelet: diff --git a/templates/bindings/camel-k/rabbitmq-source-binding.yaml b/templates/bindings/camel-k/rabbitmq-source-binding.yaml index dd39500..87c2ac2 100644 --- a/templates/bindings/camel-k/rabbitmq-source-binding.yaml +++ b/templates/bindings/camel-k/rabbitmq-source-binding.yaml @@ -9,10 +9,8 @@ spec: apiVersion: camel.apache.org/v1alpha1 name: rabbitmq-source properties: - addresses: "The Addresses" + addresses: "localhost:5672" exchangeName: "The Exchange name" - password: "The Password" - username: "The Username" sink: ref: kind: KafkaTopic diff --git a/templates/bindings/core/rabbitmq-source-binding.yaml b/templates/bindings/core/rabbitmq-source-binding.yaml index 180e242..a01d58e 100644 --- a/templates/bindings/core/rabbitmq-source-binding.yaml +++ b/templates/bindings/core/rabbitmq-source-binding.yaml @@ -2,10 +2,8 @@ from: uri: "kamelet:rabbitmq-source" parameters: - addresses: "The Addresses" + addresses: "localhost:5672" exchangeName: "The Exchange name" - password: "The Password" - username: "The Username" steps: - to: uri: "log:info"