Manual Kafka Data Processing

The workflow JSON

Copy or download the full n8n JSON below. Paste it into a new n8n workflow, add your credentials, activate. Full import guide →

{
  "createdAt": "2021-03-11T14:51:32.026Z",
  "updatedAt": "2021-03-18T10:28:03.209Z",
  "id": "126",
  "name": "Kafka",
  "active": false,
  "nodes": [
    {
      "parameters": {},
      "name": "Start",
      "type": "n8n-nodes-base.start",
      "typeVersion": 1,
      "position": [
        250,
        300
      ],
      "id": "76f28c5d-1894-4d95-ab23-4e6e39bf69e9"
    },
    {
      "parameters": {
        "topic": "=TopicTest{{Date.now()}}",
        "headersUi": {
          "headerValues": []
        },
        "options": {
          "compression": true
        }
      },
      "name": "Kafka",
      "type": "n8n-nodes-base.kafka",
      "typeVersion": 1,
      "position": [
        710,
        300
      ],
      "credentials": {
        "kafka": {
          "name": "<your credential>"
        }
      },
      "id": "9d37ab21-f676-4e88-8d71-3033d301ed62"
    },
    {
      "parameters": {
        "values": {
          "string": [
            {
              "name": "input",
              "value": "={{(new Date()).toISOString()}}"
            }
          ]
        },
        "options": {}
      },
      "name": "Set",
      "type": "n8n-nodes-base.set",
      "typeVersion": 1,
      "position": [
        500,
        300
      ],
      "id": "2d1bf06b-6d8e-4f82-b56f-7fde44b74007"
    }
  ],
  "connections": {
    "Set": {
      "main": [
        [
          {
            "node": "Kafka",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Start": {
      "main": [
        [
          {
            "node": "Set",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  },
  "settings": {},
  "staticData": null,
  "meta": null,
  "versionId": null,
  "triggerCount": 0,
  "tags": []
}

Credentials you'll need

Each integration node will prompt for credentials when you import. We strip credential IDs before publishing — you'll add your own.

• kafka

About this workflow

Kafka. Uses start, kafka. Manual trigger; 3 nodes.

Source: https://github.com/n8n-io/test-workflows/blob/b37961bd0e1f34e1bffb4be4a345c08ede317689/workflows/126.json — original creator credit. Request a take-down →

More General workflows → · Browse all categories →

Related workflows

Workflows that share integrations, category, or trigger type with this one. All free to copy and import.