KCQL generate schema with namespace

Question

KCQL generate schema with namespace

Closed this issue 6 years ago · 1 comments

Hi, i currently use stream-reactor to import from MQTT into kafka and use JsonSimpleConverter to parse records. The JsonSimpleConverter will automatically create a schema for record, but schema lack of namespace.
It's possible to set schema namespace use kcql in connector properties file? Thanks!

Answer 1 · 2018-04-16T05:58:07.000Z

It's turn out to include schema namespce, you have to define schema maually and use AvroConverter

com.datamountaineer.streamreactor.connect.converters.source.AvroConverter

in properties file and provide schema defition file as well.