如何用 Python 实现读取 Kafka 数据写入阿里云 OSS

Question

1. 想实现用 Python 直接读取 Kafka 数据，不落本地磁盘，直接写入阿里云 OSS，有没有什么思路？
2. 有没有什么插件可以从 Kafka 直接导入数据到阿里云OSS？

Answer 1

第一步：读kafka 第二步：写OSS