JSON Schema support for direct Kafka connections