Skip to content
This repository has been archived by the owner on Jul 20, 2023. It is now read-only.
/ trino-event-stream Public archive

Stream events from trino to a kafka topic

License

Notifications You must be signed in to change notification settings

IBM/trino-event-stream

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

25 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Trino event stream

Development guide

A Trino plugin to stream trino events into a Kafka topic.

It implements the io.trino.spi.eventlistern.EventListener interface.

Install

Run mvn install to build this plugin, then put the plugin file trino-event-stream-352.zip to the plugin folder of trino server.

Configuration

Create new properties file event-listener.properties inside the /etc/trino directory:

event-listener.name=event-stream
bootstrap.servers=broker:9092
key.serializer=org.apache.kafka.common.serialization.StringSerializer
value.serializer=org.apache.kafka.common.serialization.StringSerializer

Avro formatter is added to serialize messages generated from QueryCreatedEvent, QueryCompletedEvent. Avro formatted messages would be read as String using the StringSerializer Then it will emit events to the Kafka topic trino.event.