JSON Message Decoder - StarTree Docs

The JSON message decoder is used in real-time ingestion to decode JSON-formatted messages from Kafka topic and convert them into Pinot rows.

Class

org.apache.pinot.plugin.inputformat.json.JSONMessageDecoder

Configuration Example

Define it in your streamConfig within the table config:

"streamConfig": {
  "streamType": "kafka",
  "stream.kafka.topic.name": "events_topic",
  "stream.kafka.consumer.type": "lowlevel",
  "stream.kafka.decoder.class.name": "org.apache.pinot.plugin.inputformat.json.JSONMessageDecoder",
  "stream.kafka.broker.list": "broker:9092"
}

Decoder Behavior

Parses JSON strings using a fast JSON library (e.g., Jackson/Gson).
Converts each key-value pair into Pinot column values.
Logs and skips invalid or malformed messages.

⌘I