在我的项目中，我将使用 flink statefun kafka ingress 来消耗来自 kafka 的 avro 序列化记录，但似乎没有配置参数供用户指定用于反序列化 kafka 记录密钥的反序列化器，在源代码RoutableKafkaIngressDeserializer中，我还注意到密钥直接从字节数组转换为字符串。
我尝试通过kafka消费者属性key.deserializer指定反序列化器，但是根据flink kafka附加属性不是可行的解决方案
我发现可以通过 datastream API Kafka deserializer 指定 kafka 反序列化器，不幸的是，这个配置目前在 flink statefun kafka ingress 中似乎不可用。