Kafka Subscribe

Import data from Kafka.

Properties

Name		Type
engine		String=kafka:subscribe
brokers		Array
group		String
topics		Array
decoder		String
schema		Object

---

engine

Must be kafka:subscribe.

Required

Yes

---

brokers

Your Kafka brokers.

Required

Yes

Unique Items

true

Min Items

1

---

group

The Kafka consumer group.

Required

Yes

---

topics

The Kafka topics to subscribe to.

Required

No

Unique Items

true

Min Items

1

---

decoder

The format of the data. See Parsing Data for details.

Required

Yes

Enum

csv json ndjson msgpack protobuf parquet html xml regex

---

schema

Define a schema for the data.

Required

Yes