【发布时间】:2020-06-01 10:00:27
【问题描述】:
我从未使用过 AMQ Streams (Kafka)。如何通过路由(读取/创建/删除)连接到主题?对于 Kafka,例如在我的本地机器上,我使用 CLI 和基本命令。但是对于 AMQ Streams,我只有路线。这是一个 HTTPS URL。
【问题讨论】:
标签: apache-kafka openshift amq
我从未使用过 AMQ Streams (Kafka)。如何通过路由(读取/创建/删除)连接到主题?对于 Kafka,例如在我的本地机器上,我使用 CLI 和基本命令。但是对于 AMQ Streams,我只有路线。这是一个 HTTPS URL。
【问题讨论】:
标签: apache-kafka openshift amq
我猜您正在使用 AMQ Streams Operator 来运行您的 Pod。 following blog post 中有很好的解释如何使用 OpenShift Routes 连接到 Kafka。
可以通过在Kafka 对象中定义它来公开路由,如下所示:
apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
name: my-cluster
spec:
kafka:
# ...
listeners:
# ...
external:
type: route
# ...
【讨论】: