+ {
+ "id": "892cacf32948fe41",
+ "type": "function",
+ "z": "db7b8dca98eba850",
+ "name": "http-preparation",
+ "func": "const protocol = env.get('KAFKA_BRIDGE_PROTOCOL');\nconst host = env.get('KAFKA_BRIDGE_HOST');\nconst port = env.get('KAFKA_BRIDGE_PORT');\nconst base = protocol + '://' + host + ':' + port;\nconst group = env.get('KAFKA_BRIDGE_CONSUMER_GROUP');\nconst name = env.get('KAFKA_BRIDGE_CONSUMER_NAME');\nmsg.url = [base, msg.topic, group, 'instances', name].join('/');\nmsg.method = 'delete';\nmsg.headers = {\n 'content-type': 'application/vnd.kafka.v2+json',\n accept: 'application/vnd.kafka.v2+json'\n}\nmsg.payload = null\n\nreturn msg;\n",
+ "outputs": 1,
+ "noerr": 0,
+ "initialize": "",
+ "finalize": "",
+ "libs": [],
+ "x": 340,
+ "y": 460,
+ "wires": [
+ [
+ "53aae16b268527f7"
+ ]
+ ]
+ },
+ {
+ "id": "ca171245ae7b6184",
+ "type": "inject",
+ "z": "db7b8dca98eba850",
+ "name": "DeleteConsumer",
+ "props": [
+ {
+ "p": "payload"
+ },
+ {
+ "p": "topic",
+ "vt": "str"
+ }
+ ],
+ "repeat": "",
+ "crontab": "",
+ "once": false,
+ "onceDelay": "0.5",
+ "topic": "consumers",
+ "payload": "",
+ "payloadType": "date",
+ "x": 140,
+ "y": 460,
+ "wires": [
+ [
+ "892cacf32948fe41"
+ ]
+ ]
+ },