You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ts...@apache.org on 2022/08/22 03:29:54 UTC
[camel-k-examples] 09/10: improve timer-source-log-sink example
This is an automated email from the ASF dual-hosted git repository.
tsato pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k-examples.git
commit 95c7e518b09d11218da90454b51572b17d425f72
Author: Kuthumi Pepple <ku...@gmail.com>
AuthorDate: Sat Aug 20 10:07:39 2022 +0100
improve timer-source-log-sink example
---
.../timer-source-log-sink/log-sink.kamelet.yaml | 2 +-
.../kamelets/timer-source-log-sink/readme.md | 17 ++++++++++-------
.../timer-source-log-sink/timer-source.kamelet.yaml | 6 +++---
3 files changed, 14 insertions(+), 11 deletions(-)
diff --git a/generic-examples/kamelets/timer-source-log-sink/log-sink.kamelet.yaml b/generic-examples/kamelets/timer-source-log-sink/log-sink.kamelet.yaml
index 399341e..ee0766c 100644
--- a/generic-examples/kamelets/timer-source-log-sink/log-sink.kamelet.yaml
+++ b/generic-examples/kamelets/timer-source-log-sink/log-sink.kamelet.yaml
@@ -31,4 +31,4 @@ spec:
from:
uri: kamelet:source
steps:
- - to: "log:sink"
+ - to: "log:sink"
diff --git a/generic-examples/kamelets/timer-source-log-sink/readme.md b/generic-examples/kamelets/timer-source-log-sink/readme.md
index 4d4d671..3948acd 100644
--- a/generic-examples/kamelets/timer-source-log-sink/readme.md
+++ b/generic-examples/kamelets/timer-source-log-sink/readme.md
@@ -2,9 +2,12 @@
This example shows how to create a simple timer `event source` and a log `event sink`. The timer events emitted are consumed by a simple logging connector which will print out those events.
+## Additional requirement for running this example
+- You should have Knative properly installed on your cluster ([see installation guide](https://knative.dev/docs/install/))
+
## Create events source and sink
-Let's start by creating the timer event source and log event sink as `kamelet`s.
+Let's start by creating the timer event source and log event sink as `kamelets`.
```
$ kubectl apply -f timer-source.kamelet.yaml
$ kubectl apply -f log-sink.kamelet.yaml
@@ -52,11 +55,11 @@ After a while you will be able to watch the event consumed by the underlying `lo
```
$ kamel log log-event-sink
-[1] Monitoring pod log-event-sink-wjm9w-deployment-cf4f49655-xwq82
+[1] Monitoring pod log-event-sink-00001-deployment-7cf6d488c9-2nbx8
...
-[1] 2020-10-23 14:28:11,878 INFO [sink] (vert.x-worker-thread-1) Exchange[ExchangePattern: InOnly, BodyType: byte[], Body: Hello world!]
-[1] 2020-10-23 14:28:11,877 INFO [sink] (vert.x-worker-thread-0) Exchange[ExchangePattern: InOnly, BodyType: byte[], Body: Hello world!]
-[1] 2020-10-23 14:28:12,381 INFO [sink] (vert.x-worker-thread-2) Exchange[ExchangePattern: InOnly, BodyType: byte[], Body: Hello world!]
-[1] 2020-10-23 14:28:13,276 INFO [sink] (vert.x-worker-thread-3) Exchange[ExchangePattern: InOnly, BodyType: byte[], Body: Hello world!]
-[1] 2020-10-23 14:28:14,299 INFO [sink] (vert.x-worker-thread-4) Exchange[ExchangePattern: InOnly, BodyType: byte[], Body: Hello world!]
+[1] 2022-08-20 08:56:01,284 INFO [sink] (executor-thread-0) Exchange[ExchangePattern: InOnly, BodyType: byte[], Body: Hello world!]
+[1] 2022-08-20 08:56:02,284 INFO [sink] (executor-thread-0) Exchange[ExchangePattern: InOnly, BodyType: byte[], Body: Hello world!]
+[1] 2022-08-20 08:56:03,285 INFO [sink] (executor-thread-0) Exchange[ExchangePattern: InOnly, BodyType: byte[], Body: Hello world!]
+[1] 2022-08-20 08:56:04,286 INFO [sink] (executor-thread-0) Exchange[ExchangePattern: InOnly, BodyType: byte[], Body: Hello world!]
+[1] 2022-08-20 08:56:05,285 INFO [sink] (executor-thread-0) Exchange[ExchangePattern: InOnly, BodyType: byte[], Body: Hello world!]
```
\ No newline at end of file
diff --git a/generic-examples/kamelets/timer-source-log-sink/timer-source.kamelet.yaml b/generic-examples/kamelets/timer-source-log-sink/timer-source.kamelet.yaml
index 0428c77..1bc4304 100644
--- a/generic-examples/kamelets/timer-source-log-sink/timer-source.kamelet.yaml
+++ b/generic-examples/kamelets/timer-source-log-sink/timer-source.kamelet.yaml
@@ -49,6 +49,6 @@ spec:
parameters:
period: "{{period}}"
steps:
- - set-body:
- constant: "{{message}}"
- - to: "kamelet:sink"
\ No newline at end of file
+ - set-body:
+ constant: "{{message}}"
+ - to: "kamelet:sink"