Kafka¶

Node: kafka · Full type: n8n-nodes-base.kafka · Version: 1

Credentials¶

kafka (alias: @kafka)

CREDENTIAL @kafka = kafka "My Kafka"

Parameter	Type	Default	Details
`topic`	string	""
`sendInputData`	boolean	true
`message`	string	""
`jsonParameters`	boolean	false
`useSchemaRegistry`	boolean	false
`schemaRegistryUrl`	string	""	required
`useKey`	boolean	false
`key`	string	""	required
`eventName`	string	""	required
`headersUi`	fixedCollection	{}	groups: `headerValues`
`headerParametersJson`	json	""
`options`	collection	{}	keys: `acks`, `compression`, `timeout`

headersUi children:

headerValues group:

Parameter	Type	Default	Details
`key`	string	""
`value`	string	""

options children:

Parameter	Type	Default
`acks`	boolean	false
`compression`	boolean	false
`timeout`	number	30000

NODE "kafka" @kafka AS "Kafka" {
  schemaRegistryUrl: {{ $json.schemaRegistryUrl }},
  key: {{ $json.key }},
  eventName: {{ $json.eventName }}
}