我有一个服务,我想发布事件到多个代理,[一个在不同的命名空间]。问题是,即使我已经设置了多个Sinkbinding,K_SINK被注入到服务pod中,只有一个代理端点,而不是两个。我错过了什么,或者有更好的方式发布事件到多个代理,除了硬编码Knative Broker Ingress URL并基于代理名称和命名空间在代码中动态创建完整的URL之外?
最终,我只想发布不同的Kafka主题。
我有一个服务,我想发布事件到多个代理,[一个在不同的命名空间]。问题是,即使我已经设置了多个Sinkbinding,K_SINK被注入到服务pod中,只有一个代理端点,而不是两个。我错过了什么,或者有更好的方式发布事件到多个代理,除了硬编码Knative Broker Ingress URL并基于代理名称和命名空间在代码中动态创建完整的URL之外?
最终,我只想发布不同的Kafka主题。
1条答案
按热度按时间nszi6y051#
在一个SinkBinding中有多个
K_SINK
是不可能的。所以你可以为此创建一个feature request。在此期间,你可以做的是将你的SinkBinding的sink指向Broker。然后为这个Broker设置多个Trigger,将事件发送到一个Sink(或者如果你只想要不同的主题,一个KafkaSink):
字符串
在SinkBinding中,接收器是Broker,主体是Service,然后Service在
K_SINK
中获取Brokers地址。