我有一个要求，我们的应用程序之外的源程序将把一个文件放到一个s3 bucket中，我们必须将其加载到kafka主题中。我正在研究confluent的s3源连接器，目前正在定义在我们的环境中设置连接器的配置。但有几篇文章指出，只有在使用s3sink连接器将文件放入s3时，才能使用s3源连接器。
以上是真的吗？我在何处/使用什么属性来定义配置中的输出主题？当阅读s3并将其放入主题中时，这些消息是否可以转换。两者都是json/avro格式。
confluent的快速入门示例还假设您已经使用了s3接收器连接器，因此有了这个问题。
谢谢您