JSON
Decode JSON-formatted messages from Kafka topics into Pinot rows during real-time ingestion.
Avro
Ingest Avro-encoded Kafka messages using schemas managed in Confluent Schema Registry.
Protobuf
Ingest Protobuf-encoded Kafka messages with schemas from Confluent Schema Registry.
Debezium CDC
Consume Debezium CDC data from MySQL or Postgres in real time via Kafka or Kinesis.
DynamoDB
Ingest DynamoDB Streams CDC data in real time without complex transformations.
Prometheus
Ingest Prometheus-formatted metrics data natively into Pinot tables.
AWS Glue Schema Registry
Decode Avro messages from Kafka or MSK with schemas managed in AWS Glue Schema Registry.