Using the `kafka-console-producer.sh`
> Note: 0xb6 is invalid character
```
>Malalažbeta my weird character \xb6
```
```
[2018-08-21T16:47:17.375Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Found 1 messages with a total size of 117 bytes
[2018-08-21T16:47:17.375Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Firing trigger with 1 messages
[2018-08-21T16:47:17.389Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Repsonse status code 202
[2018-08-21T16:47:17.389Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Fired trigger with activation
a42be62478264a30abe6247826fa300e
```
```
➜ openwhisk master ✗ bin/wsk -i --apihost 172.17.0.1 --auth
789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP
activation get a42be62478264a30abe6247826fa300e
ok: got activation a42be62478264a30abe6247826fa300e
{
"namespace": "whisk.system",
"name": "kafkatrigger",
"version": "0.0.1",
"subject": "whisk.system",
"activationId": "a42be62478264a30abe6247826fa300e",
"start": 1534870037386,
"end": 0,
"duration": 0,
"response": {
"status": "success",
"statusCode": 0,
"success": true,
"result": {
"messages": [
{
"key": null,
"offset": 44600,
"partition": 0,
"topic": "test",
"value": "Malalažbeta my weird character \\xb6"
}
]
}
},
"logs": [
"{\"statusCode\":0,\"success\":true,\"activationId\":\"6ca9b6b7b1514c7aa9b6b7b1515c7a86\",\"rule\":\"whisk.system/myrule\",\"action\":\"whisk.system/myecho\"}"
],
"annotations": [],
"publish": false
}
```
```
>"Malalažbeta my weird character \xb6"
```
```
[2018-08-21T16:51:00.471Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Found 1 messages with a total size of 121 bytes
[2018-08-21T16:51:00.471Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Firing trigger with 1 messages
[2018-08-21T16:51:00.520Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Repsonse status code 202
[2018-08-21T16:51:00.521Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Fired trigger with activation
d76bfb31c36b4c22abfb31c36bec2243
```
```
➜ openwhisk master ✗ bin/wsk -i --apihost 172.17.0.1 --auth
789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP
activation get d76bfb31c36b4c22abfb31c36bec2243
ok: got activation d76bfb31c36b4c22abfb31c36bec2243
{
"namespace": "whisk.system",
"name": "kafkatrigger",
"version": "0.0.1",
"subject": "whisk.system",
"activationId": "d76bfb31c36b4c22abfb31c36bec2243",
"start": 1534870260518,
"end": 0,
"duration": 0,
"response": {
"status": "success",
"statusCode": 0,
"success": true,
"result": {
"messages": [
{
"key": null,
"offset": 44601,
"partition": 0,
"topic": "test",
"value": "\"Malalažbeta my weird character \\xb6\""
}
]
}
},
"logs": [
"{\"statusCode\":0,\"success\":true,\"activationId\":\"7ba23bc128794a85a23bc128791a85b6\",\"rule\":\"whisk.system/myrule\",\"action\":\"whisk.system/myecho\"}"
],
"annotations": [],
"publish": false
}
```
```
>{"hello": "Malalažbeta my weird character \xb6"}
```
```
[2018-08-21T16:53:43.249Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Found 1 messages with a total size of 134 bytes
[2018-08-21T16:53:43.249Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Firing trigger with 1 messages
[2018-08-21T16:53:43.267Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Repsonse status code 202
[2018-08-21T16:53:43.267Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Fired trigger with activation
a0897002581948948970025819589491
```
```
➜ openwhisk master ✗ bin/wsk -i --apihost 172.17.0.1 --auth
789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP
activation get a0897002581948948970025819589491
ok: got activation a0897002581948948970025819589491
{
"namespace": "whisk.system",
"name": "kafkatrigger",
"version": "0.0.1",
"subject": "whisk.system",
"activationId": "a0897002581948948970025819589491",
"start": 1534870423265,
"end": 0,
"duration": 0,
"response": {
"status": "success",
"statusCode": 0,
"success": true,
"result": {
"messages": [
{
"key": null,
"offset": 44602,
"partition": 0,
"topic": "test",
"value": "{\"hello\": \"Malalažbeta my weird character
\\xb6\"}"
}
]
}
},
"logs": [
"{\"statusCode\":0,\"success\":true,\"activationId\":\"64ef9022f17f4a49af9022f17f1a49e6\",\"rule\":\"whisk.system/myrule\",\"action\":\"whisk.system/myecho\"}"
],
"annotations": [],
"publish": false
}
```
```
>"{"hello": "Malalažbeta my weird character \xb6"}"
```
```
[2018-08-21T16:55:28.677Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Found 1 messages with a total size of 138 bytes
[2018-08-21T16:55:28.678Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Firing trigger with 1 messages
[2018-08-21T16:55:28.689Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Repsonse status code 202
[2018-08-21T16:55:28.689Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Fired trigger with activation
eed5d571becf431195d571becfe3116e
```
```
➜ openwhisk master ✗ bin/wsk -i --apihost 172.17.0.1 --auth
789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP
activation get eed5d571becf431195d571becfe3116e
ok: got activation eed5d571becf431195d571becfe3116e
{
"namespace": "whisk.system",
"name": "kafkatrigger",
"version": "0.0.1",
"subject": "whisk.system",
"activationId": "eed5d571becf431195d571becfe3116e",
"start": 1534870528687,
"end": 0,
"duration": 0,
"response": {
"status": "success",
"statusCode": 0,
"success": true,
"result": {
"messages": [
{
"key": null,
"offset": 44603,
"partition": 0,
"topic": "test",
"value": "\"{\"hello\": \"Malalažbeta my weird character
\\xb6\"}\""
}
]
}
},
"logs": [
"{\"statusCode\":0,\"success\":true,\"activationId\":\"84bbce9c128b480bbbce9c128be80bbc\",\"rule\":\"whisk.system/myrule\",\"action\":\"whisk.system/myecho\"}"
],
"annotations": [],
"publish": false
}
```
```
>"{\"hello\": \"Malalažbeta my weird character \xb6\"}"
```
```
[2018-08-21T16:57:56.258Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Found 1 messages with a total size of 146 bytes
[2018-08-21T16:57:56.259Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Firing trigger with 1 messages
[2018-08-21T16:57:56.283Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Repsonse status code 202
[2018-08-21T16:57:56.284Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Fired trigger with activation
a4d5fd5140f543e095fd5140f5e3e087
```
```
➜ openwhisk master ✗ bin/wsk -i --apihost 172.17.0.1 --auth
789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP
activation get a4d5fd5140f543e095fd5140f5e3e087
ok: got activation a4d5fd5140f543e095fd5140f5e3e087
{
"namespace": "whisk.system",
"name": "kafkatrigger",
"version": "0.0.1",
"subject": "whisk.system",
"activationId": "a4d5fd5140f543e095fd5140f5e3e087",
"start": 1534870676281,
"end": 0,
"duration": 0,
"response": {
"status": "success",
"statusCode": 0,
"success": true,
"result": {
"messages": [
{
"key": null,
"offset": 44604,
"partition": 0,
"topic": "test",
"value": "\"{\\\"hello\\\": \\\"Malalažbeta my weird
character \\xb6\\\"}\""
}
]
}
},
"logs": [
"{\"statusCode\":0,\"success\":true,\"activationId\":\"30c16a3120124617816a312012c61718\",\"rule\":\"whisk.system/myrule\",\"action\":\"whisk.system/myecho\"}"
],
"annotations": [],
"publish": false
}
```
```
>{\"hello\": \"Malalažbeta my weird character \xb6\"}
```
```
[2018-08-21T17:00:01.670Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Found 1 messages with a total size of 142 bytes
[2018-08-21T17:00:01.672Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Firing trigger with 1 messages
[2018-08-21T17:00:01.684Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Repsonse status code 202
[2018-08-21T17:00:01.684Z] [INFO] [??] [kafkatriggers]
[/whisk.system/kafkatrigger] Fired trigger with activation
5276f991ecbd4189b6f991ecbdc189fe
```
```
➜ openwhisk master ✗ bin/wsk -i --apihost 172.17.0.1 --auth
789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP
activation get 5276f991ecbd4189b6f991ecbdc189fe
ok: got activation 5276f991ecbd4189b6f991ecbdc189fe
{
"namespace": "whisk.system",
"name": "kafkatrigger",
"version": "0.0.1",
"subject": "whisk.system",
"activationId": "5276f991ecbd4189b6f991ecbdc189fe",
"start": 1534870801679,
"end": 0,
"duration": 0,
"response": {
"status": "success",
"statusCode": 0,
"success": true,
"result": {
"messages": [
{
"key": null,
"offset": 44605,
"partition": 0,
"topic": "test",
"value": "{\\\"hello\\\": \\\"Malalažbeta my weird
character \\xb6\\\"}"
}
]
}
},
"logs": [
"{\"statusCode\":0,\"success\":true,\"activationId\":\"decb6c86ffa242148b6c86ffa2b2147f\",\"rule\":\"whisk.system/myrule\",\"action\":\"whisk.system/myecho\"}"
],
"annotations": [],
"publish": false
}
```
[ Full content available at:
https://github.com/apache/incubator-openwhisk-package-kafka/pull/279 ]
This message was relayed via gitbox.apache.org for [email protected]
