zhy989 commented on issue #210: How to use message feed URL: https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-321508475 @bjustin-ibm thanks in case 1: Should I register a new accoun on the local host for message hub? in case 2: I tried this CLI "wsk trigger create MyKafkaTrigger -f /whisk.system/messaging/kafkaFeed -p brokers "mykafkahost:9092,mykafkahost:9093" -p topic mytopic -p isJSONData true -i", and got the same error - wsk trigger create MyKafkaTrigger -f /whisk.system/messaging/kafkaFeed -p brokers "mykafkahost:9092,mykafkahost:9093" -p topic mytopic -p isJSONData true -i ok: invoked /whisk.system/messaging/kafkaFeed with id fff3cab0fde142e98ac81ba3a98db38c { "activationId": "fff3cab0fde142e98ac81ba3a98db38c", "annotations": [ { "key": "limits", "value": { "logs": 10, "memory": 256, "timeout": 60000 } }, { "key": "path", "value": "whisk.system/messaging/kafkaFeed" } ], "duration": 991, "end": 1502359181855, "logs": [], "name": "kafkaFeed", "namespace": "whisk.system", "publish": false, "response": { "result": { "error": "Error: error happened in your connection" }, "status": "application error", "success": false }, "start": 1502359180864, "subject": "whisk.system", "version": "0.0.2" } ok: invoked /whisk.system/messaging/kafkaFeed with id c0cb00c7f1964151a2aabd5f35ef8d4f { "activationId": "c0cb00c7f1964151a2aabd5f35ef8d4f", "annotations": [ { "key": "limits", "value": { "logs": 10, "memory": 256, "timeout": 60000 } }, { "key": "path", "value": "whisk.system/messaging/kafkaFeed" } ], "duration": 501, "end": 1502359182811, "logs": [], "name": "kafkaFeed", "namespace": "whisk.system", "publish": false, "response": { "result": {}, "status": "success", "success": true }, "start": 1502359182310, "subject": "whisk.system", "version": "0.0.2" } ok: deleted trigger MyKafkaTrigger - wsk -i activation logs fff3cab0fde142e98ac81ba3a98db38c 2017-08-10T09:59:41.851044685Z stdout: Error creating trigger: { 2017-08-10T09:59:41.851069919Z stdout: "name": "StatusCodeError", 2017-08-10T09:59:41.851073662Z stdout: "statusCode": 500, 2017-08-10T09:59:41.851076502Z stdout: "message": "500 - \"Error: error happened in your connection\"", 2017-08-10T09:59:41.851081688Z stdout: "error": "Error: error happened in your connection", 2017-08-10T09:59:41.851084534Z stdout: "options": { 2017-08-10T09:59:41.851087266Z stdout: "method": "PUT", 2017-08-10T09:59:41.851090286Z stdout: "url": "https://172.17.0.1/api/v1/web/whisk.system/messagingWeb/kafkaFeedWeb.http";, 2017-08-10T09:59:41.85109325Z stdout: "rejectUnauthorized": false, 2017-08-10T09:59:41.851095837Z stdout: "json": true, 2017-08-10T09:59:41.851098218Z stdout: "body": { 2017-08-10T09:59:41.851100973Z stdout: "authKey": "789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP", 2017-08-10T09:59:41.851103755Z stdout: "isJSONData": true, 2017-08-10T09:59:41.851107298Z stdout: "brokers": "mykafkahost:9092,mykafkahost:9093", 2017-08-10T09:59:41.851109876Z stdout: "topic": "mytopic", 2017-08-10T09:59:41.851112397Z stdout: "triggerName": "/whisk.system/MyKafkaTrigger" 2017-08-10T09:59:41.851115008Z stdout: }, 2017-08-10T09:59:41.851117353Z stdout: "headers": { 2017-08-10T09:59:41.851119788Z stdout: "Content-Type": "application/json", 2017-08-10T09:59:41.851122322Z stdout: "Accept": "text/plain", 2017-08-10T09:59:41.851150998Z stdout: "User-Agent": "whisk" 2017-08-10T09:59:41.851155301Z stdout: }, 2017-08-10T09:59:41.851157521Z stdout: "simple": true, 2017-08-10T09:59:41.851160009Z stdout: "resolveWithFullResponse": false, 2017-08-10T09:59:41.851162485Z stdout: "transform2xxOnly": false 2017-08-10T09:59:41.851164913Z stdout: }, 2017-08-10T09:59:41.851167255Z stdout: "response": { 2017-08-10T09:59:41.851170448Z stdout: "statusCode": 500, 2017-08-10T09:59:41.851172917Z stdout: "body": "Error: error happened in your connection", 2017-08-10T09:59:41.85117544Z stdout: "headers": { 2017-08-10T09:59:41.851177892Z stdout: "server": "nginx/1.11.13", 2017-08-10T09:59:41.851180284Z stdout: "date": "Thu, 10 Aug 2017 09:59:41 GMT", 2017-08-10T09:59:41.851182731Z stdout: "content-type": "text/plain", 2017-08-10T09:59:41.851185084Z stdout: "content-length": "40", 2017-08-10T09:59:41.851187482Z stdout: "connection": "close", 2017-08-10T09:59:41.851189864Z stdout: "access-control-allow-origin": "*", 2017-08-10T09:59:41.851192389Z stdout: "access-control-allow-methods": "OPTIONS, GET, DELETE, POST, PUT, HEAD, PATCH", 2017-08-10T09:59:41.851202513Z stdout: "access-control-allow-headers": "Authorization, Content-Type" 2017-08-10T09:59:41.851204948Z stdout: }, 2017-08-10T09:59:41.851206935Z stdout: "request": { 2017-08-10T09:59:41.851209048Z stdout: "uri": { 2017-08-10T09:59:41.851211189Z stdout: "protocol": "https:", 2017-08-10T09:59:41.851213461Z stdout: "slashes": true, 2017-08-10T09:59:41.851215585Z stdout: "auth": null, 2017-08-10T09:59:41.8512177Z stdout: "host": "172.17.0.1", 2017-08-10T09:59:41.851219983Z stdout: "port": 443, 2017-08-10T09:59:41.851222118Z stdout: "hostname": "172.17.0.1", 2017-08-10T09:59:41.85122426Z stdout: "hash": null, 2017-08-10T09:59:41.85122631Z stdout: "search": null, 2017-08-10T09:59:41.85122837Z stdout: "query": null, 2017-08-10T09:59:41.851230457Z stdout: "pathname": "/api/v1/web/whisk.system/messagingWeb/kafkaFeedWeb.http", 2017-08-10T09:59:41.851232714Z stdout: "path": "/api/v1/web/whisk.system/messagingWeb/kafkaFeedWeb.http", 2017-08-10T09:59:41.851238986Z stdout: "href": "https://172.17.0.1/api/v1/web/whisk.system/messagingWeb/kafkaFeedWeb.http"; 2017-08-10T09:59:41.851241403Z stdout: }, 2017-08-10T09:59:41.851243452Z stdout: "method": "PUT", 2017-08-10T09:59:41.851245659Z stdout: "headers": { 2017-08-10T09:59:41.851247768Z stdout: "Content-Type": "application/json", 2017-08-10T09:59:41.85125001Z stdout: "Accept": "text/plain", 2017-08-10T09:59:41.851252218Z stdout: "User-Agent": "whisk", 2017-08-10T09:59:41.85125436Z stdout: "content-length": 242 2017-08-10T09:59:41.851256519Z stdout: } 2017-08-10T09:59:41.851258496Z stdout: } 2017-08-10T09:59:41.851260433Z stdout: } 2017-08-10T09:59:41.851262341Z stdout: } Should I start up the catalog_kafkatrigger container before create the trigger ? if do and how to start up that container? ---------------------------------------------------------------- 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: us...@infra.apache.org
With regards, Apache Git Services
