问题标签 [strimzi]

我们有一个由 3 个节点组成的连接集群。我们的连接集群信任库中需要几个证书。我们通过以下方式安装了这些证书。

如您所知，在三个连接集群启动后，证书已安装到以下信任库/tmp/kafka/cluster.truststore.p12中。此外，我们可以在以下文件中找到随机信任库密码：/tmp/strimzi-connect.properties.

我们将信任库路径和信任库密码定向到 KafkaConnector 资源文件中。

现在我们正在进入其中一个连接集群 pod，从/tmp/strimzi-connect.properties文件中获取密码，然后在sol.ssl_trust_store_password字段中使用密码。

我的问题：

有什么方法可以参数化密码吗？使用密码的任何封装方式（这样我们就不需要进入 pod 来知道密码 - 期望是，kafkaconnector 资源将从/tmp/strimzi-connect.properties文件中获取密码，它在哪个 pod 上运行）

我已经按如下方式配置了外部侦听器和 ACL（它们是功能性的）

这托管在 AKS 群集上。从本地消费它确实已经工作并且也可以从集群内部生产，但使用publicIP:9094作为 bootstrapServers。

我想在集群内添加一个生产者并使用 9092 端口（BootstrapServers = "my-cluster-kafka-bootstrap:9092"我想像这样），但需要付出最少的努力（如果可能的话，即使没有 ACL，也没有任何身份验证，没有任何加密）。

会推荐什么？

先感谢您！

我已经在 kubernetes 上部署了 srimzi kafka，并且在我的本地也有 kube 设置。但是每次我想在 kafka 中创建一个新主题时，我都需要通过 Rancher 导入 yaml 文件并提供主题名称来创建一个。

有没有办法直接通过 kubectl 命令创建 kafka 主题？

这些是我用来运行 kafka 的命令：

Producer: kubectl run kafka-producer1 -ti --image=strimzi/kafka:0.18.0-kafka-2.4.0 --rm=true --restart=Never -- bin/kafka-console-producer.sh --broker-list 11.23.41.32:31025 --topic topic-name

Consumer: kubectl run kafka-consumer1 -ti --image=strimzi/kafka:0.18.0-kafka-2.4.0 --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server 11.23.41.32:31025 --topic topic-name --from-beginning

我们正在使用骆驼 kafka 组件连接到 Kafka 集群。当我的应用程序启动时，我看到以下错误。你能帮我看看这些错误是什么意思吗？我确信客户端无法连接到引导服务器。我故意掩盖了引导服务器的 ip 和端口

我的软件级别是

• 骆驼：3.1.0
• 卡夫卡客户端：2.5.0

Kafka 集群级别

• Strimzi -0.18.0
• 卡夫卡：2.5.0

我有一个脚本可以在 cmd 上执行一组命令。但我收到以下错误

代码：

错误： File "Producer.py", line 40, in <module> subprocess.run(['kubectl', 'run',podName, File "C:\Users\AngadiVB\AppData\Local\Programs\Python\Python38-32\lib\site-packages\run\__init__.py", line 145, in __new__ process = cls.create_process(command, stdin, cwd=cwd, env=env, shell=shell) File "C:\Users\AngadiVB\AppData\Local\Programs\Python\Python38-32\lib\site-packages\run\__init__.py", line 121, in create_process shlex.split(command), File "C:\Users\AngadiVB\AppData\Local\Programs\Python\Python38-32\lib\shlex.py", line 311, in split return list(lex) File "C:\Users\AngadiVB\AppData\Local\Programs\Python\Python38-32\lib\shlex.py", line 300, in __next__ token = self.get_token() File "C:\Users\AngadiVB\AppData\Local\Programs\Python\Python38-32\lib\shlex.py", line 109, in get_token raw = self.read_token() File "C:\Users\AngadiVB\AppData\Local\Programs\Python\Python38-32\lib\shlex.py", line 140, in read_token nextchar = self.instream.read(1) AttributeError: 'list' object has no attribute 'read'

注意：第 40 行是 subprocess.run

我有一个来自订阅主题的消费者轮询。它消耗每条消息并进行一些处理（在几秒钟内），推送到不同的主题并提交偏移量。

总共有5000条消息，

重启前 - 消耗了 2900 条消息并提交了偏移量

重新启动后 - 从偏移量 0 开始消耗。

即使消费者是使用相同的消费者组创建的，它也会从偏移量 0 开始处理消息。

kafka 版本 (strimzi) > 2.0.0 kafka-python == 2.0.1

问题：由于某种原因，客户端 pod 只能解析完全限定的完全限定 DNS 名称，包括集群服务后缀。

这个问题在这个问题中说明了： AKS, WINdows Node, dns does not resolve service until fully qualified name is used

为了解决这个问题，我使用了 useServiceDnsDomain 标志。文档（https://strimzi.io/docs/operators/master/using.html#type-GenericKafkaListenerConfiguration-schema-reference）将其解释为

配置是否应使用 Kubernetes 服务 DNS 域。如果设置为 true，则生成的地址包含服务 DNS 域后缀（默认为 .cluster.local，可以使用环境变量 KUBERNETES_SERVICE_DNS_DOMAIN 进行配置）。默认为 false。此字段只能与内部类型侦听器一起使用。

我的部分yaml如下

这没有做任何事情，所以我也尝试添加 KUBERNETES_SERVICE_DNS_DOMAIN 如下所示

srimzi/operator:0.20.0 图像正在使用中。

在我的客户端（.net Confluent.Kafka 1.4.4）中，我使用 tt-kafka-kafka-bootstrap.shared.svc.cluster.local 作为 BootstrapServers。它给了我错误

错误：GroupCoordinator：无法解析“tt-kafka-kafka-2.tt-kafka-kafka-brokers.shared.svc:9092”：不知道这样的主机。

我期望代理服务向客户端提供全名，但从错误看来 useServiceDnsDomain 没有效果。

任何帮助表示赞赏。谢谢。

嘿，我正在使用 Kafka Strimzi。我使用以下 yml 文件创建了我的 kafkaTopic 和 KafkaUser：

和

[kafka@my-cluster-zookeeper-0 kafka]$ bin/kafka-topics.sh --list --zookeeper 10.101.97.123:2181

当我使用这个命令时，我收到了这个错误，不知道如何解决这个问题。

列出我的 kafkaTopics 时遇到此问题。请帮助我。

我正在使用带有 srimzi 运算符的 Kafka。我不知道如何使用 KafkaUser 任何人都可以向我建议我应该在哪里学习它的实际实现。我刚刚创建了一个 Kafka 用户和 KafkaTopic，现在我完全不知道该做什么。这是我的 KafkaUSer yml 代码：

这是我的 KafkaTopic yml 文件代码：

我正在使用带有 srimzi 运算符的 Kafka，我创建了一个 Kafka 集群，并且还使用 yml 文件部署了 Kafka 连接。但在此之后我完全空白下一步该做什么。我读到 Kafka 连接用于将数据从源复制到 Kafka 集群或从 Kafka 集群复制到另一个目的地。我想使用 Kafka 连接将数据从文件复制到 Kafka 集群的任何主题。任何人都可以帮助我如何做到这一点，我正在共享 yml 文件，我使用该文件创建了我的 Kafka 连接集群。

@kubeclt create -f kafka-connect.yml -n strimzi

在 Kafka connect 的 pod 处于运行状态之后，我不知道下一步该做什么。请帮我。