apache-kafka - Kafka AMQ 流 - 主题命令

Question

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

Answer 1

我猜你正在使用 AMQ Streams Operator 来运行你的 Pod。以下博客文章中有一个很好的解释，说明了如何使用 OpenShift Routes 连接到 Kafka。

Route 可以通过在Kafka对象中定义它来公开，如下所示：

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