Example for Kafka Connector with Schema Registry and TopicRecordNameStrategy

[kstrempel]

Hello,

I'm trying to get trino running together with Kafka. I got most of it working.
Parsing JSON or using a Schema Registry with TopicNameStrategy just works.

But in my company we are using the TopicRecordNameStrategy.
In the documentation there is a part that is describing how to do it with trino.
But to be honest I don't understand how to do that.

Link

Where should I add the table names with the value and key annotation.

Would be very nice to get some help for that.

Thanks in advance!

[kstrempel]

Ahh now I found it by myself.

show tables; is not working when the TopicRecordNameStrategy is used.

But query a topic working like documented.

In my case