Using scala/GettingStarted as a base, I added code to utilize the TableAPI and a kafka connector. Then received this error:

Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a connector using option: 'connector'='kafka'

The example build.sbt does not support assembling an uber jar which preserves the Service Provider Interface required by Flink.

I suggest the build.sbt examples are updated or a new scala example is created which demonstrates how to use the TableAPI.