Reference: KAFKA support in Presto cluster


Qubole does package a KAFKA connector for the Presto cluster.

The configuration files and the table definition files (mentioned in the tutorials) needs to be created under the "Override Presto Configuration" option under "Presto Settings" on the Cluster Configuration page through the UI.

Pushing these configuration settings while the cluster is running is not supported and hence you need to add these configurations first and then restart the cluster.



‌• Information on configuring a KAFKA connector can be found here:


‌• There are some KAFKA tutorials found here:




1. Adding this to presto overrides in cluster config:





will create the etc/catalog/ mentioned in:



2. Similarly etc/kafka/tpch.customer.json file mentioned in:


can be created by adding this to presto overrides:



{ "tableName": "customer", "schemaName": "tpch", .... }


More information about presto overrides section can be obtained here:



Since Kinesis connector is similar to kafka connector, this can be also useful in figuring out how to write such configs in cluster config:

-> s

Have more questions? Submit a request


Powered by Zendesk