Avro

To maintain data type consistency during aggregation, the ksqlDB STREAMs (applied to both input and output topics) must use the AVRO format for their values.

The connector retrieves the AVRO schema associated with the output topic in ksqlDB via HTTP. It then adjusts the schema of incoming Kafka records to align with this output schema, ensuring compatibility and data integrity throughout the aggregation process.