Skip to main content

StarTree

In this guide, you'll learn how to use Estuary Flow to push data streams to StarTree using the Kafka data source.

StarTree is a real-time analytics platform built on Apache Pinot, designed for performing fast, low-latency analytics on large-scale data.

Connecting Estuary Flow to StarTree​

  1. Generate a refresh token to use for the StarTree connection. You can generate this token from the Estuary Admin Dashboard.

  2. In the StarTree UI, navigate to the Data Sources section and choose Add New Data Source.

  3. Select Kafka as your data source type.

  4. Enter the following connection details:

    Create StarTree Connection

    • Bootstrap Servers: dekaf.estuary.dev
    • Security Protocol: SASL_SSL
    • SASL Mechanism: PLAIN
    • SASL Username: {}
    • SASL Password: Your generated Estuary Refresh Token

  5. Configure Schema Registry: To decode Avro messages, enable schema registry settings:

    • Schema Registry URL: https://dekaf.estuary.dev
    • Schema Registry Username: {} (same as SASL Username)
    • Schema Registry Password: The same Estuary Refresh Token as above

  6. Click Create Connection to proceed.