我需要从 Kafka 主题中获取消息并通过基于 HTTP 的 API 通知其他系统。也就是说，从主题获取消息，映射到第 3 方 API 并调用它们。我打算为此编写一个 Kafka Sink 连接器。
对于这个用例，Kafka Connect 是正确的选择还是我应该使用 Kafka Client。
我需要代表一组刚刚公开REST API的懒惰消费者来使用消息.因此,我计划让Sink连接器从Kafka主题中获取消息,并对公开的API执行HTTP POST操作.
需要考虑的关键因素之一是限制.您建议使用什么机制来限制Sink Tasks以满足API的层SLA.我知道Kafka有客户端配额功能,但是,跟踪API请求/ min或sec的最佳机制是什么,这将允许动态调整客户端配额？