This is an automated email from the ASF dual-hosted git repository.
pefernan pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-kie-kogito-examples.git
The following commit(s) were added to refs/heads/main by this push:
new 2a8521c23 NO_ISSUE: Fix Kafka examples README.md (#1941)
2a8521c23 is described below
commit 2a8521c239f42d7bab5253182e1b4d8efac91380
Author: Pere Fernández <[email protected]>
AuthorDate: Wed Jun 5 17:54:51 2024 +0200
NO_ISSUE: Fix Kafka examples README.md (#1941)
---
.../process-kafka-avro-multi-quarkus/README.md | 9 ++--
.../process-kafka-multi-quarkus/README.md | 14 +++---
.../process-kafka-quickstart-quarkus/README.md | 52 +++++++++++-----------
.../process-kafka-multi-springboot/README.md | 14 +++---
.../process-kafka-quickstart-springboot/README.md | 12 ++---
5 files changed, 49 insertions(+), 52 deletions(-)
diff --git a/kogito-quarkus-examples/process-kafka-avro-multi-quarkus/README.md
b/kogito-quarkus-examples/process-kafka-avro-multi-quarkus/README.md
index 0ab8afde4..de9a02a36 100644
--- a/kogito-quarkus-examples/process-kafka-avro-multi-quarkus/README.md
+++ b/kogito-quarkus-examples/process-kafka-avro-multi-quarkus/README.md
@@ -14,13 +14,12 @@ A quick reminder of what the original example was doing:
* if not processed traveller, info is logged and then process instance
finishes sending a reply to a different Kafka topic
The functionality is still the same, but the format of the event, rather than
being a cloudevent JSON format, it is a representation of the traveller object
using Avro format. To help us deal with the serialization details,
-[jackson-kafka-avro-serializer](https://github.com/productboardlabs/jackson-kafka-avro-serializer)
dependency is added to `pom.xml`
+`kie-addons-quarkus-marshallers-avro` dependency is added to `pom.xml`
```
- <dependency>
- <groupId>io.github.productboardlabs</groupId>
- <artifactId>jackson-kafka-avro-serializer</artifactId>
- <version>0.7.0</version>
+ <dependency>
+ <groupId>org.kie</groupId>
+ <artifactId>kie-addons-quarkus-marshallers-avro</artifactId>
</dependency>
```
diff --git a/kogito-quarkus-examples/process-kafka-multi-quarkus/README.md
b/kogito-quarkus-examples/process-kafka-multi-quarkus/README.md
index 4521b4df2..1bb522d90 100644
--- a/kogito-quarkus-examples/process-kafka-multi-quarkus/README.md
+++ b/kogito-quarkus-examples/process-kafka-multi-quarkus/README.md
@@ -166,11 +166,11 @@ Content (cloud event format)
```json
{
- "specversion": "0.3",
+ "specversion": "1.0",
"id": "21627e26-31eb-43e7-8343-92a696fd96b1",
"source": "",
- "type": "TravellersMessageDataEvent_3",
- "time": "2022-02-24T13:25:16+0000",
+ "type": "travellers",
+ "time": "2022-02-24T13:25:16Z",
"data": {
"firstName" : "Jan",
"lastName" : "Kowalski",
@@ -182,7 +182,7 @@ Content (cloud event format)
One liner
```json
-{"specversion": "0.3","id": "21627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16Z","data": { "firstName" :
"Jan", "lastName" : "Kowalski", "email" : "[email protected]",
"nationality" : "Polish"}}
+{"specversion": "1.0","id": "21627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16Z","data": { "firstName" :
"Jan", "lastName" : "Kowalski", "email" : "[email protected]",
"nationality" : "Polish"}}
```
@@ -212,7 +212,7 @@ this will then trigger the successful processing of the
traveller and put anothe
}
```
-there are bunch of extension attributes that starts with `kogito` to provide
some context of the execution and the event producer.
+there is a bunch of extension attributes that starts with `kogito` to provide
some context of the execution and the event producer.
To take the other path of the process put following message on `travellers`
topic
@@ -226,7 +226,7 @@ With the following content (Cloud Event Format)
```json
{
- "specversion": "0.3",
+ "specversion": "1.0",
"id": "31627e26-31eb-43e7-8343-92a696fd96b1",
"source": "",
"type": "travellers",
@@ -243,7 +243,7 @@ With the following content (Cloud Event Format)
One Liner
```json
-{"specversion": "0.3","id": "31627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16Z","data": { "firstName" :
"John", "lastName" : "Doe", "email" : "[email protected]", "nationality" :
"American"}}
+{"specversion": "1.0","id": "31627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16Z","data": { "firstName" :
"John", "lastName" : "Doe", "email" : "[email protected]", "nationality" :
"American"}}
```
this will result in message being send to `cancelledtravelers` topic,
according to this configuration
diff --git a/kogito-quarkus-examples/process-kafka-quickstart-quarkus/README.md
b/kogito-quarkus-examples/process-kafka-quickstart-quarkus/README.md
index 2ebc63198..1992bea86 100644
--- a/kogito-quarkus-examples/process-kafka-quickstart-quarkus/README.md
+++ b/kogito-quarkus-examples/process-kafka-quickstart-quarkus/README.md
@@ -159,11 +159,11 @@ Content (cloud event format)
```json
{
- "specversion": "0.3",
+ "specversion": "1.0",
"id": "21627e26-31eb-43e7-8343-92a696fd96b1",
"source": "",
"type": "travellers",
- "time": "2022-02-24T13:25:16+0000",
+ "time": "2022-02-24T13:25:16Z",
"data": {
"firstName" : "Jan",
"lastName" : "Kowalski",
@@ -175,7 +175,7 @@ Content (cloud event format)
One liner
```json
-{"specversion": "0.3","id": "21627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16+0000","data": {
"firstName" : "Jan", "lastName" : "Kowalski", "email" :
"[email protected]", "nationality" : "Polish"}}
+{"specversion": "1.0","id": "21627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16Z","data": { "firstName" :
"Jan", "lastName" : "Kowalski", "email" : "[email protected]",
"nationality" : "Polish"}}
```
@@ -183,29 +183,27 @@ this will then trigger the successful processing of the
traveller and put anothe
```json
{
- "specversion": "0.3",
- "id": "86f69dd6-7145-4188-aeaa-e44622eeec86",
- "source": "",
- "type": "TravellersMessageDataEvent_3",
- "time": "2019-10-03T16:22:40.373523+02:00[Europe/Warsaw]",
- "data": {
- "firstName": "Jan",
- "lastName": "Kowalski",
- "email": "[email protected]",
- "nationality": "Polish",
- "processed": true
- },
- "kogitoProcessinstanceId": "4fb091c2-82f7-4655-8687-245a4ab07483",
- "kogitoParentProcessinstanceId": null,
- "kogitoRootProcessinstanceId": null,
- "kogitoProcessId": "Travellers",
- "kogitoRootProcessId": null,
- "kogitoProcessinstanceState": "1",
- "kogitoReferenceId": null
+ "specversion": "1.0",
+ "id": "e84a4591-3581-42cd-bb2a-fac989ffd1a0",
+ "source": "/process/Travelers",
+ "type": "processedtravellers",
+ "time": "2024-06-05T11:30:49.722368+02:00",
+ "kogitoproctype": "BPMN",
+ "kogitoprocinstanceid": "66d1c981-9d6d-4c01-bc43-b712dc73b6cc",
+ "kogitoprocist": "Active",
+ "kogitoprocversion": "1.0",
+ "kogitoprocid": "Travelers",
+ "data": {
+ "firstName": "Jan",
+ "lastName": "Kowalski",
+ "email": "[email protected]",
+ "nationality": "Polish",
+ "processed": true
+ }
}
```
-there are bunch of extension attributes that starts with `kogito` to provide
some context of the execution and the event producer.
+there are a bunch of extension attributes that starts with `kogito` to provide
some context of the execution and the event producer.
To take the other path of the process put following message on `travellers`
topic
@@ -219,11 +217,11 @@ With the following content (Cloud Event Format)
```json
{
- "specversion": "0.3",
+ "specversion": "1.0",
"id": "31627e26-31eb-43e7-8343-92a696fd96b1",
"source": "",
"type": "travellers",
- "time": "2022-02-24T13:25:16+0000",
+ "time": "2022-02-24T13:25:16Z",
"data": {
"firstName" : "John",
"lastName" : "Doe",
@@ -236,7 +234,7 @@ With the following content (Cloud Event Format)
One Liner
```json
-{"specversion": "0.3","id": "31627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16+0000","data": {
"firstName" : "John", "lastName" : "Doe", "email" : "[email protected]",
"nationality" : "American"}}
+{"specversion": "1.0","id": "31627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16Z","data": { "firstName" :
"John", "lastName" : "Doe", "email" : "[email protected]", "nationality" :
"American"}}
```
-this will not result in message being send to `processedtravelers` topic.
+this will not result in message being sent to `processedtravelers` topic.
diff --git
a/kogito-springboot-examples/process-kafka-multi-springboot/README.md
b/kogito-springboot-examples/process-kafka-multi-springboot/README.md
index 0d2adfcbc..a9272de1a 100644
--- a/kogito-springboot-examples/process-kafka-multi-springboot/README.md
+++ b/kogito-springboot-examples/process-kafka-multi-springboot/README.md
@@ -137,11 +137,11 @@ Content (cloud event format)
```json
{
- "specversion": "0.3",
+ "specversion": "1.0",
"id": "21627e26-31eb-43e7-8343-92a696fd96b1",
"source": "",
- "type": "travellers",
- "time": "2022-02-24T13:25:16+0000",
+ "type": "travellers",
+ "time": "2022-02-24T13:25:16Z",
"data": {
"firstName" : "Jan",
"lastName" : "Kowalski",
@@ -153,7 +153,7 @@ Content (cloud event format)
One liner
```json
-{"specversion": "0.3","id": "21627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16+0000","data": {
"firstName" : "Jan", "lastName" : "Kowalski", "email" :
"[email protected]", "nationality" : "Polish"}}
+{"specversion": "1.0","id": "21627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16Z","data": { "firstName" :
"Jan", "lastName" : "Kowalski", "email" : "[email protected]",
"nationality" : "Polish"}}
```
this will then trigger the successful processing of the traveller and put
another message on `processedtravellers` topic.
@@ -169,11 +169,11 @@ With the following content (Cloud Event Format)
```json
{
- "specversion": "0.3",
+ "specversion": "1.0",
"id": "31627e26-31eb-43e7-8343-92a696fd96b1",
"source": "",
"type": "travellers",
- "time": "2022-02-24T13:25:16+0000",
+ "time": "2022-02-24T13:25:16Z",
"data": {
"firstName" : "John",
"lastName" : "Doe",
@@ -186,7 +186,7 @@ With the following content (Cloud Event Format)
One Liner
```json
-{"specversion": "0.3","id": "31627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16+0000","data": {
"firstName" : "John", "lastName" : "Doe", "email" : "[email protected]",
"nationality" : "American"}}
+{"specversion": "1.0","id": "31627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16Z","data": { "firstName" :
"John", "lastName" : "Doe", "email" : "[email protected]", "nationality" :
"American"}}
```
this will result in message being send to `cancelledtravelers` topic.
diff --git
a/kogito-springboot-examples/process-kafka-quickstart-springboot/README.md
b/kogito-springboot-examples/process-kafka-quickstart-springboot/README.md
index 576a91921..894885e0f 100644
--- a/kogito-springboot-examples/process-kafka-quickstart-springboot/README.md
+++ b/kogito-springboot-examples/process-kafka-quickstart-springboot/README.md
@@ -130,11 +130,11 @@ Content (cloud event format)
```json
{
- "specversion": "0.3",
+ "specversion": "1.0",
"id": "21627e26-31eb-43e7-8343-92a696fd96b1",
"source": "",
"type": "travellers",
- "time": "2022-02-24T13:25:16+0000",
+ "time": "2022-02-24T13:25:16Z",
"data": {
"firstName" : "Jan",
"lastName" : "Kowalski",
@@ -146,7 +146,7 @@ Content (cloud event format)
One liner
```json
-{"specversion": "0.3","id": "21627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16+0000","data": {
"firstName" : "Jan", "lastName" : "Kowalski", "email" :
"[email protected]", "nationality" : "Polish"}}
+{"specversion": "1.0","id": "21627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16Z","data": { "firstName" :
"Jan", "lastName" : "Kowalski", "email" : "[email protected]",
"nationality" : "Polish"}}
```
this will then trigger the successful processing of the traveller and put
another message on `processedtravellers` topic.
@@ -162,11 +162,11 @@ With the following content (Cloud Event Format)
```json
{
- "specversion": "0.3",
+ "specversion": "1.0",
"id": "31627e26-31eb-43e7-8343-92a696fd96b1",
"source": "",
"type": "travellers",
- "time": "2022-02-24T13:25:16+0000",
+ "time": "2022-02-24T13:25:16Z",
"data": {
"firstName" : "John",
"lastName" : "Doe",
@@ -179,7 +179,7 @@ With the following content (Cloud Event Format)
One Liner
```json
-{"specversion": "0.3","id": "31627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16+0000","data": {
"firstName" : "John", "lastName" : "Doe", "email" : "[email protected]",
"nationality" : "American"}}
+{"specversion": "1.0","id": "31627e26-31eb-43e7-8343-92a696fd96b1","source":
"","type": "travellers", "time": "2022-02-24T13:25:16Z","data": { "firstName" :
"John", "lastName" : "Doe", "email" : "[email protected]", "nationality" :
"American"}}
```
this will not result in message being send to `processedtravelers` topic.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
