问题标签 [strimzi]

默认情况下，当我们创建 Strimzi-Kafka 用户时，用户会在 Kubernetes secrets-manager 中创建自己的 user.crt 和 user.key，但我想使用自己的 user.crt 和 user.key，这可行吗？

而不是先创建用户，然后用我们自己的密钥替换！我们是否可以选择传递我们自己的 crt，运行时用户创建的键？我们可以在部署文件中以某种方式指定吗？

来自官方文档：我得到了这个https://strimzi.io/docs/master/#installing-your-own-ca-certificates-str但它kind:Kafka不是kind:KafkaUser因为我们知道kind:KafkaUser用于用户创建。

我按照下面的链接在 k8s 中创建了 srimzi 集群运算符

https://medium.com/@sincysebastian/setup-kafka-with-debezium-using-strimzi-in-kubernetes-efd494642585

下载 srimzi 0.17.0 版本并解压。我跑了 Kubectl apply -f apply install/cluster-operator 。我收到错误“检测版本失败”并且它的套接字连接超时。

为了解决问题，我在 cluster-operator conf 文件中添加了 STRIMZI_KUBERNETES_VERSION 。现在我收到“检测 routes.openshift.io/API 失败。API 将被禁用”。

我认为这是网络策略问题并添加以允许所有端口。得到相同的错误。...出口：- {} 入口：- {}

谁能帮我弄清楚我在这里缺少什么以及如何在 k8s 中使用 debezuim 制作它。

提前致谢。

我为 Kafka 部署了 Strimzi 运算符并启用了 TLS/ACL，现在我被卡住了！如何在创建的 9093 个传递用户上运行 producer.sh/consumer.sh？

以下是在端口 9092 上禁用 ACL 的命令：

但是，如果我在上述命令中启用 ACL、TLS 并使用 9093，那么我该如何传递 Kafka 用户详细信息进行身份验证？

@Jakub @ppatierno 将很高兴收到您的帮助。

非常感谢， 苏迪尔

我们在 Strimzi kafkaconnect 集群上运行了 13 个 kafka debezium postgres 连接器。其中之一是失败Caused by: java.lang.OutOfMemoryError: Java heap space。将 jvm 选项从 2g 增加到 4g，但仍然因同样的问题而失败。

完整的日志：

在这一点上，我对这个平台还不是很熟悉，所以请多多包涵。我的 devops 团队使用 strimzi 在 k8s 的 docker 容器中设置了 kafka 连接服务实例。连接服务似乎运行正常，但它们不断（每 30 秒）记录此错误：

设置它的团队告诉我他们不知道如何修复它。它似乎并没有造成太大的伤害，但我对 1) 日志混乱和 2) 显然在服务中配置错误的东西不满意。我浏览了一些文档，但是TBH，我在这一点上有点迷茫。

如果有人熟悉这种行为，你能给我指出如何解决这个问题的参考吗？谢谢，JS

Kafka 弹性搜索连接器“confluentinc-kafka-connect-elasticsearch-5.5.0”在本地无法正常工作。

我还在同一路径中使用 mssql 连接器和 s3 连接器插件；它们可以工作，但 elasticsearch 插件给出 noclassfound 错误。这是我在worker中的文件夹结构：

我已经阅读了一些消息，其中缺少弹性搜索连接器中的 jar 文件/依赖项，我添加了它们，如您在上面看到的，但没有运气。

这是我的连接器配置：

我将用户名/密码更改为明文；没运气。我尝试了两个 http/https 的弹性搜索连接，没有运气。

这是我的弹性搜索 srv 信息：

我可以通过两种方式从 Kafka Connect Worker 连接到弹性搜索服务：

无论我做什么，异常都不会改变。我不知道还有什么可以尝试的。我的大脑在燃烧，我快要疯了。

我是否遗漏了什么，或者您能否建议你们如何在 Kubernetes 上运行此连接器？

感谢和问候

我想使用参考文档https://ibm-cloud-architecture.github.io/refarch-eda/scenarios/connect-s3/在 kubernetes 中部署 S3 kafka sink 连接器（使用 Apache Camel）

此 Kubernetes 部署文件中使用的DateTime 占位符（${date:now:yyyyMMdd-HHmmssSSS}未解析。而 ${file:} 已解析。

我在本文档中看到了 ${date:now:yyyyMMdd} 和 exchangeId ( https://camel.apache.org/components/latest/languages/simple-language.html )

寻找连接到 Strimzi kafka 集群的 UI 工具，以获得对 kafka 主题的可见性，读取主题中的消息、代理和分区详细信息以及连接或不连接 SSL/SASL 连接的能力。我已经尝试使用 kafka 工具并面临问题因此寻找替代方案）。请建议一些相同的 UI 工具？（类似于融合中心/kafka 工具），它们要么免费，要么成本最低。

这些段在我们的 Kafka 集群中滚动得如此之快，这可能是因为我们正在将具有微秒时间戳的记录生成到 kafka 集群中，而 Kafka 期望它以毫秒为单位。是否可以在 debezium postgres 连接器中将其更改为毫秒？我应该使用哪个配置来使数据以毫秒为单位？由于这个问题，我们的 kafka 集群不稳定。

配置

现在，我需要将一些主题从一个 Kafka 集群复制到另一个，但在第二个中我需要以另一种格式。我们在 Kubernetes 中使用 Strimzi。在某些连接器中可以做这样的事情，但我不确定 MirrorMaker2 是否让我们这样做，因为它基于 Kafka Connect：