Does anyone have an example in PyFlink (1.17) how ...
# troubleshooting
y
Does anyone have an example in PyFlink (1.17) how to send a dict to kafka using AvroRowSerializationSchema?