我正在尝试使用 Flink 摄取 VPC 流日志（VPC 流日志 -> CloudWatch -> Kinesis Data Stream -> Flink）。
虽然我可以看到 Flink 管道中的记录，但我无法解析它们。我怀疑我收到的不是字符串流日志消息，而是压缩+base64+聚合记录（根据this AWS doc page）。
是这样吗？如果是，FlinkKinesisConsumer 是否支持此类日志的反序列化/分解？或者我是否必须实现自己的自定义反序列化器才能在我的 Flink 应用程序中实际处理流日志字符串？