我从未使用过AMQ Streams(Kafka)。如何通过路由连接到主题(读/创建/删除)?对于Kafka,例如在本地计算机上,我将CLI与基本命令配合使用。但是有了AMQ Streams,我只有路线。这是一个HTTPS URL。
我猜您正在使用AMQ Streams运算符来运行Pod。 following blog post中有一个很好的解释,说明如何使用OpenShift路由连接到Kafka。
可以通过在Kafka
对象中定义路径来公开该路径,如下所示:
apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
name: my-cluster
spec:
kafka:
# ...
listeners:
# ...
external:
type: route
# ...