You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@openwhisk.apache.org by GitBox <gi...@apache.org> on 2018/08/21 17:01:19 UTC
[GitHub] abaruni commented on issue #279: WIP: remove encoding check
abaruni commented on issue #279: WIP: remove encoding check
URL: https://github.com/apache/incubator-openwhisk-package-kafka/pull/279#issuecomment-414747431
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
}
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services