diff --git a/5.bindings/deploy/kafka.yaml b/5.bindings/deploy/kafka.yaml index 3ece9eb2..87f2e353 100644 --- a/5.bindings/deploy/kafka.yaml +++ b/5.bindings/deploy/kafka.yaml @@ -1,15 +1,15 @@ apiVersion: actions.io/v1alpha1 kind: Component metadata: - name: sith + name: sample spec: type: bindings.kafka metadata: - name: topics - value: sith + value: sample - name: brokers value: 10.0.181.114:9092 - name: consumerGroup value: group1 - name: publishTopic - value: sith \ No newline at end of file + value: sample \ No newline at end of file diff --git a/5.bindings/docker/docker-compose-single-broker.yml b/5.bindings/docker/docker-compose-single-broker.yml index e35780ea..3213974a 100644 --- a/5.bindings/docker/docker-compose-single-broker.yml +++ b/5.bindings/docker/docker-compose-single-broker.yml @@ -10,7 +10,7 @@ services: - "9092:9092" environment: KAFKA_ADVERTISED_HOST_NAME: 127.0.0.1 - KAFKA_CREATE_TOPICS: "sith:1:1" + KAFKA_CREATE_TOPICS: "sample:1:1" KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 volumes: - /var/run/docker.sock:/var/run/docker.sock \ No newline at end of file diff --git a/5.bindings/node/app.js b/5.bindings/node/app.js index 7ec5c9cb..35132319 100644 --- a/5.bindings/node/app.js +++ b/5.bindings/node/app.js @@ -8,7 +8,7 @@ app.use(bodyParser.json()); const port = 3000; -app.post('/sith', (req, res) => { +app.post('/sample-topic', (req, res) => { console.log("Hello from Kafka!"); console.log(req.body); res.status(200).send(); diff --git a/5.bindings/node/components/kafka.yaml b/5.bindings/node/components/kafka.yaml index a9ea46c6..44d9f436 100644 --- a/5.bindings/node/components/kafka.yaml +++ b/5.bindings/node/components/kafka.yaml @@ -1,12 +1,12 @@ apiVersion: actions.io/v1alpha1 kind: Component metadata: - name: sith + name: sample-topic spec: type: bindings.kafka metadata: - name: topics - value: sith + value: sample-topic - name: brokers value: localhost:9092 - name: consumerGroup diff --git a/5.bindings/python/app.py b/5.bindings/python/app.py index baefe93e..fee895da 100644 --- a/5.bindings/python/app.py +++ b/5.bindings/python/app.py @@ -2,7 +2,7 @@ import time import requests import os -actions_url = "http://localhost:5000/v1.0/bindings/sith" +actions_url = "http://localhost:5000/v1.0/bindings/sample-topic" n = 0 while True: n += 1 diff --git a/5.bindings/python/components/kafka.yaml b/5.bindings/python/components/kafka.yaml index d60d6248..3db43c82 100644 --- a/5.bindings/python/components/kafka.yaml +++ b/5.bindings/python/components/kafka.yaml @@ -1,11 +1,11 @@ apiVersion: actions.io/v1alpha1 kind: Component metadata: - name: sith + name: sample-topic spec: type: bindings.kafka metadata: - name: brokers value: localhost:9092 - name: publishTopic - value: sith \ No newline at end of file + value: sample-topic \ No newline at end of file