Kafka Extended Trigger icon

Kafka Extended Trigger

Consume messages from Kafka with compression and Schema Registry support

Kafka Extended Trigger

AI-generated

Summary

Consume messages from a Kafka topic

Inputs

None.

Output shape

array of message objects

Each emission is an array containing one or more message objects. Each message object has a json field with topic, partition, offset, timestamp, key, value, and optionally headers.

Examples

Example 1: Simple JSON consumption

Topic: orders, Group ID: n8n-workflow, From Beginning: false, JSON Parse Message: true, Batch Size: 5

Links

Discussion