我不清楚是否有某种插件可以使用来自 kafka 主题的数据并将它们插入到 S3。
我已经找到了这个topic , 但我还不能解决这个问题，有这个 project , 但老实说很难用，因为最后一次提交是 2 年前的。
对我来说，它的主要目标是直接从 kafka 消费以激发工作，但我认为这可能有点复杂，所以如果可以用来自 kafka 的事件片段填充 S3 对我来说就足够了。
此外，scala中有任何消费者示例吗？这有点有趣，因为 kafka 是用 scala 构建的，但文档代码是 java。 =p
感谢任何帮助
更新:
Camus也可能是一个选择
最佳答案
pinterest 的这个工具对我来说是完美的答案。
关于java - Kafka 到 S3 - 如何将切片从 kafka 加载到 S3，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/25120893/