From 9ca407cfc54c5372f0ca1e59902da1a4467ea53d Mon Sep 17 00:00:00 2001 From: Paolo Patierno Date: Sat, 8 Feb 2020 19:18:48 +0100 Subject: [PATCH] Removed useless fields in the trigger declaration --- KafkaTwitterTrigger/function.json | 6 +----- deploy/deploy.yaml | 4 ---- 2 files changed, 1 insertion(+), 9 deletions(-) diff --git a/KafkaTwitterTrigger/function.json b/KafkaTwitterTrigger/function.json index 8b1da0c..b23052c 100644 --- a/KafkaTwitterTrigger/function.json +++ b/KafkaTwitterTrigger/function.json @@ -1,13 +1,9 @@ { "bindings": [ { - "type": "kafkaTrigger", - "direction": "in", - "name": "event", "topic": "twitter", "brokerList": "kafka-cp-kafka-headless.default.svc.cluster.local:9092", - "consumerGroup": "functions", - "dataType": "binary" + "consumerGroup": "functions" } ], "scriptFile": "../dist/KafkaTwitterTrigger/index.js" diff --git a/deploy/deploy.yaml b/deploy/deploy.yaml index 4d14d42..3b921b7 100644 --- a/deploy/deploy.yaml +++ b/deploy/deploy.yaml @@ -47,13 +47,9 @@ spec: triggers: - type: kafka metadata: - type: kafkaTrigger - direction: in - name: event topic: twitter brokerList: kafka-cp-kafka-headless.default.svc.cluster.local:9092 consumerGroup: functions - dataType: binary lagThreshold: '5' ---