我有一个API，它根据输入的有效负载提供数据，其中包括国家和周数。我的目标是从这个API中检索数据并将其发布到Kafka主题。虽然我知道我可以为此任务创建一个自定义生产者应用程序，但我有兴趣探索使用Kafka Connect实现这一目标的可能性。
我知道存在用于Kafka Connect的HTTP源连接器，但我没有遇到任何清晰的示例来演示如何在向API发出请求时传递动态负载。
有没有人使用Kafka Connect成功地完成了类似的任务，特别是在处理需要动态负载的API时？任何指导，示例或建议都将非常感谢。