供应商发布对驻留在供应商dc中的kafka主题的频繁异步响应。我们需要把这些信息输入我们公司。我们不想做的是：
写一个（轮询）Kafka消费服务来读取他们的Kafka主题
我们希望他们调用restapi（回调url）来发布信息。
在kafka主题上配置触发器以在消息写入主题时调用（外部）restapi有什么选项吗？
我们希望他们调用我们的api，这样我们就可以通过我们的api网关路由它，并处理所有横切关注点。
供应商发布对驻留在供应商dc中的kafka主题的频繁异步响应。我们需要把这些信息输入我们公司。我们不想做的是：
写一个（轮询）Kafka消费服务来读取他们的Kafka主题
我们希望他们调用restapi（回调url）来发布信息。
在kafka主题上配置触发器以在消息写入主题时调用（外部）restapi有什么选项吗？
我们希望他们调用我们的api，这样我们就可以通过我们的api网关路由它，并处理所有横切关注点。
1条答案
按热度按时间ego6inou1#
如果你想让他们给你的服务打电话，或者让他们在任何地方写第二个事件，那么你需要让他们这么做。。。没有真正的选择。
如果您可以访问他们的kafka服务，我看不出为什么将使用者嵌入api会是一个问题。
或者您可以使用mirrormaker/replicator将他们的Kafka复制到您自己的本地Kafka，但是您仍然需要一些消费者将数据传送到rest操作。