support for schema on write for ksql?

[aviadr1]

I'd like to use aiokafka to write to ksql streams, but aiokafka does not support specifying the schema.

confluent_kafka does support it but it is not async
any change to support schemas in aiokafka?

# how schemas are supported in confluent_kafka
from confluent_kafka.avro import AvroProducer
from confluent_kafka.avro.load import loads

key_schema_str = '{"type": "string"}'
value_schema_str = '''
{
  "namespace": "com.example",
  "type": "record",
  "name": "User",
  "fields": [
    {"name": "name", "type": "string"},
    {"name": "age", "type": "int"}
  ]
}
'''

key_schema = loads(key_schema_str)
value_schema = loads(value_schema_str)

avro_producer = AvroProducer({
    'bootstrap.servers': 'localhost:9092',
    'schema.registry.url': 'http://localhost:8081'
    }, default_key_schema=key_schema, default_value_schema=value_schema)