问题标签 [strimzi]

我有一个使用 Strimzi cluster-operator 正在运行的 Kafka-zookeeper 集群。为此，我已经关注了知识库http://strimzi.io/docs/master/。kafka 和 zookeeper 的指标可从端口 9404 获得。我必须将此集群设置配置为 Prometheus 进行监控。Strimzi 本身也有一个用于配置 Prometheus 的 KB（http://strimzi.io/docs/master/#assembly-metrics-deployment-configuration-kafka）。但我的问题是，我无法根据他们的 KB 配置集群，因为在我的 Prometheus 设置中，我必须配置服务监视器以发现应用程序，并且我需要在其服务中指定可用端口的指标。但我找不到任何解决方案。请求帮助...

我是 Open shift / OKD 的新手。我在开放班次上运行 Strimzi。

我已经部署了一个包含 Rest API 的应用程序。此应用程序具有 Rest Api，并且可以从 Rest Api 控制生产者和消费者。我已将我的应用程序的 POD 复制到 3。

为了更好地控制，我们希望亲自对每个 pod 副本进行触发查询。前任。我的应用程序的 pod-replica1kafka-testing启动 producer.pod-replica2 我的应用程序kafka-testing启动消费者，依此类推。

我们如何单独访问每个 pod-replica 来执行测试？我们不能使用相同的源创建多个应用程序。

如果有不清楚的地方，请告诉我。

多谢

尝试通过 Strimzi Operator 安装 Kafka 集群时遇到以下错误

重现步骤：

1）安装olm：

2）安装srimzi-cluster-operator：

3）安装kafka-cluster（见https://operatorhub.io/operator/strimzi-cluster-operator.v0.11.1#，在“自定义资源定义，寻找Kafka）

，其中 kafka-cluster.yaml 的内容为：

第 3 步失败并出现以下错误：

错误：无法识别“kafka-cluster.yaml”：版本“kafka.strimzi.io/v1alpha1”中的种类“Kafka”没有匹配项

有什么建议吗？谢谢。

我正在尝试使用本指南在 Openshift 平台上设置 kafka 集群： https ://developers.redhat.com/blog/2018/10/29/how-to-run-kafka-on-openshift-the-enterprise -kubernetes-with-amq-streams/

我的 zookeeper 和 kafka 集群运行如下所示： 当我的应用程序作为引导服务器运行时，我输入到 my-cluster-kafka-external 引导程序的路由。但是当我尝试向 Kafka 发送消息时，我收到了这条消息：

该主题已成功创建，并且在我的计算机上使用本地 kafka 运行时应用程序运行良好。那么我做错了什么，为什么我无法访问Kafka并发送消息？

这是我在 spring-kafka 中的 kafka 生产者配置：

编辑：我将日志记录级别设置为调试并发现：

这和connections.max.idle.ms经纪人的财产有关系吗？这里有人遇到了类似的问题。

我尝试kafka-console-producer通过运行以下命令来使用：

并在 producer.properties 中使用此配置：

但我收到回复说连接在身份验证时终止：

有没有办法证明openshift的证书是错误的？

我在 AWS 上运行的 Rancher Kuberenetes 环境中部署了 Strimzi Operator。我使用了 Strimzi 操作符来部署我的 Kafka 集群和 3 个代理。我的集群运行良好，我可以生产和消费。现在我想使用 Prometheus 和 Grafana 监控 Kafka 集群。我正在使用 Rancher 的 2.2.6 版本，所以它带有 Prometheus 和 Grafana，我想用它来监控。

我尝试了有关 Strimzi Operator 的文档，但无法获得文档中提供的指标。我的 Grafana 仪表板显示 NA 或 0。事实上，我的 Kafka 集群运行的命名空间也没有显示 u。您能否提供有关如何使用 Rancher 中内置的 Prometheus 和 Grafana 设置 Kafka 集群的指标报告的帮助？

对于那里的社区来说，这是一个非常普遍的问题，尤其是 Kafka Strimzi Bridge 的人们，如果他们正在阅读本文。

我正在尝试将他们的 Apache Kafka HTTP Bridge 实现为 POC。文档非常差，没有提供任何帮助。我真的只需要知道您如何使用桥接器发布和使用来自 Kafka 主题的消息。我已经启动了这座桥，但除此之外什么都不知道，因为文档缺少基本示例。

我创建了两个应用程序wurstmeister/kafka，zookeeper如下所示。

虽然我可以zookeeper在我的项目中看到该服务，但我没有看到 Kafka 服务。如何让我的其他 pod 连接到 Kafka？通过 pod IP 地址？但是，这不是service豆荚相互连接的方式吗？

为什么没有自动创建 Kafka 服务？

Kafka Dockerfile Zookeeper Dockerfile

我在 OpenShift 上成功设置了 Strimzi Kafka 集群。我可以看到以下服务：

• kafka-brokers
• kafka-bootstrap
• zookeeper-client
• zookeeper-nodes

这实际上与这里所说的不同；所以，不确定这是否是 Strimzi 安装问题。我从这里按照安装步骤操作。

kafka-bootstrap我为kafka-brokers端口9092（非 TLS 客户端）创建了一个路由。在这两种情况下，ECONNREFUSED当我提供路由值时都会出现错误（例如my-cluster-myproject.192.168.99.100.nip.io:9092，在kafkajs的示例中。

如何将kafkajs包连接到 Strimzi 集群？

使用 CNCF 的 Strimzi Kafka Bridge，我创建了一个小 API，可以使用 HTTP/1.1 协议与 Kafka 服务器交互。这对于请求-响应方案来说都是好事。但是，我的要求是，一旦我最好在长期 HTTP 连接上接收到事件（根据我的理解），就将在 Kafka 主题上接收到的事件流式传输到订阅的客户端（通过 Strimzi 桥）。不断地轮询网桥以获取消息并空手而归，这是对客户端资源的浪费。我希望 Kafka 服务器直接将这些事件流式传输到客户端。

我对 SSE 或 Websockets 或长轮询有点不确定。我对这些将数据流式传输到客户端的方法进行了大量阅读。但是，我无法弄清楚这些变化是在通信层还是应用层，还是两者兼而有之。

您是否只是使用传统的 HTTP 通信协议构建 API（无论技术如何）并以某种方式将其升级为使用 Websockets 还是应该将 Websockets 的使用嵌入到您的应用程序库中？

如果需要，我可以提供更多信息。Strimzi Kafka 桥网站没有提到任何关于“服务器端流”的内容，或者我可能误解了该工具的真正目的。

在此处讨论之后，我使用以下步骤启用外部客户端（基于kafkajs）连接到 OpenShift 上的 Strimzi。这些步骤来自这里。

启用外部路由

kafka-persistent-single.yaml编辑为如下所示。

提取证书，

要提取证书并在客户端使用它，我运行了以下命令：

请注意，我必须base64 -D在我的 macOS 上使用，而不是base64 -d在文档中显示。

Kafkajs客户端

npm这是根据他们的页面和文档改编的客户端。

问题

当我node sample.js从具有 的文件夹中运行时ca.crt，我收到一条连接被拒绝的消息。

我错过了什么？