Nice article Xiaoxu, have you tried to use the Python Schema Registry Client? they seem to integrate well with Faust, found about it while researching on how to use avro with Faust https://marcosschroh.github.io/python-schema-registry-client/ but I have not tired it out yet.