Support for plain text messages in KQL

[j-xella]

Trifecta v0.22.0rc8b (0.9.0.1)

I have a partition with plain text messages (created with apache kafka own test command line producers). I can see them fine one by one in Observe tab.

However, if I try to run KQL on the topic, I get various decoding error messages for each row, for example:

select * from test1 Malformed JSON message

select * from test1 with text Incompatible decoder type com.github.ldaniels528.trifecta.messages.codec.MessageCodecFactory$PlainTextCodec$