{
  "name": "kafkatrigger",
  "display_name": "Kafka Trigger",
  "description": "Consume messages from a Kafka topic",
  "group": [
    "transform"
  ],
  "versions": [
    1.0
  ],
  "inputs": 1,
  "outputs": 1,
  "credentials": [
    {
      "name": "kafka",
      "required": true
    }
  ],
  "properties": [
    {
      "name": "topic",
      "display_name": "Topic",
      "kind": "string",
      "required": true,
      "default": "",
      "description": "Name of the queue of topic to consume from"
    },
    {
      "name": "groupId",
      "display_name": "Group ID",
      "kind": "string",
      "required": true,
      "default": "",
      "description": "ID of the consumer group"
    },
    {
      "name": "resolveOffset",
      "display_name": "Resolve Offset",
      "kind": "options",
      "required": false,
      "default": "onCompletion",
      "description": "Select on which condition the offsets should be resolved. In the manual mode, when execution started by clicking on Execute Workflow or Execute Step button, offsets are always resolved immediately after message received."
    },
    {
      "name": "allowedStatuses",
      "display_name": "Allowed Statuses",
      "kind": "multiOptions",
      "required": false
    },
    {
      "name": "useSchemaRegistry",
      "display_name": "Use Schema Registry",
      "kind": "boolean",
      "required": false,
      "description": "Whether to use Confluent Schema Registry"
    },
    {
      "name": "schemaRegistryUrl",
      "display_name": "Schema Registry URL",
      "kind": "string",
      "required": true,
      "default": "",
      "description": "URL of the schema registry"
    },
    {
      "name": "options",
      "display_name": "Options",
      "kind": "collection",
      "required": false,
      "description": "Whether to allow sending message to a previously non-existing topic"
    }
  ],
  "source_path": "/home/mcochran/n8n/packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts"
}