Kafka AMQ流-主题命令

Question

我从未使用过AMQ Streams (Kafka)。如何通过路由(读取/创建/删除)连接到主题？对于Kafka，例如在我的本地机器上，我使用带有基本命令的CLI。但是对于AMQ流，我只有路由。它是一个HTTPS URL。

Answer 1

我猜你正在使用AMQ Streams操作符来运行你的Pod。关于如何使用OpenShift路由连接到Kafka，following blog post中有一个很好的解释。

通过在Kafka对象中定义路由，可以公开路由，如下所示：

apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
  name: my-cluster
spec:
  kafka:
    # ...
    listeners:
      # ...
      external:
        type: route
    # ...