在kafka bridge strimzi上启用用户名和密码
是为了增强对Kafka集群的安全性，以防止未经授权的访问和数据泄露。通过启用用户名和密码，只有经过身份验证的用户才能访问和操作Kafka集群。
Kafka Bridge是Strimzi项目的一部分，它提供了一种通过HTTP/REST接口与Kafka集群进行交互的方式。要在Kafka Bridge Strimzi上启用用户名和密码，可以按照以下步骤进行操作：
- 创建Kafka用户：首先，需要在Kafka集群中创建一个用户。可以使用Kafka提供的命令行工具或管理界面来创建用户，并为其分配相应的权限。
- 配置Kafka Bridge：接下来，需要配置Kafka Bridge以启用用户名和密码验证。可以通过修改Kafka Bridge的配置文件来实现。在配置文件中，需要指定用于身份验证的用户名和密码以及Kafka集群的连接信息。
- 启动Kafka Bridge：完成配置后，可以启动Kafka Bridge，并确保它能够成功连接到Kafka集群。在启动后，Kafka Bridge将会验证用户提供的用户名和密码，并根据其权限来限制对Kafka集群的访问。
通过启用用户名和密码，可以有效地保护Kafka Bridge Strimzi的访问权限，确保只有经过授权的用户才能使用该接口与Kafka集群进行交互。
腾讯云提供了一系列与Kafka相关的产品和服务，例如TDMQ（消息队列服务），它是腾讯云自研的分布式消息队列产品，提供高可用、高性能、可弹性扩展的消息传递服务。您可以通过以下链接了解更多关于TDMQ的信息：https://cloud.tencent.com/product/tdmq
请注意，本回答仅提供了一种实现方式，并不代表唯一的解决方案。具体的实施步骤可能因不同的环境和需求而有所变化。
相关·内容
我正在尝试添加用户名和密码到我在strimzi ..i上的kafka桥，不知道我是否配置正确，如果我配置正确，为什么我不能使用我的用户名和密码访问这里是我所做的步骤： secret.yaml apiVersion: v1
kind: Secret
metadata:
name: bridgeuser
type: Opaque
data:
my-password: cmdoR0ZETColMTY3Cg== bridge.yaml apiVersion: kafka.strimzi.io/v1alpha1
kind: KafkaBridge
metadata:
name: my-br
浏览 825提问于2021-03-30得票数 0
1回答
我有一个Strimzi集群，使用下面的yaml部署。在端口9094上启用了LoadBalancer，而没有TLS。
我已经创建了一个KafkaTopic，当我试图生成关于端口9094的主题时，它会给出TopicAuthorization异常。
# KafkaDeployment.yaml
apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
name: dataproc-poc #1
spec:
kafka:
version: 3.0.0
replicas: 3
listeners:
-
浏览 7提问于2022-01-31得票数 0
回答已采纳
1回答
通过在Kafka-Bridge.sh文件中添加以下代码行，我为Strimzi-Kafka桥启用了JMX端口。
-Dcom.sun.management.jmxremote.port=9250
-Dcom.sun.management.jmxremote.rmi.port=9250
-Dcom.sun.management.jmxremote.authenticate=false
-Dcom.sun.management.jmxremote.ssl=false
在此之后，当我运行strimzi并在JConsole中检查可用的指标时，我只能看到基本的Java指标。但是没有Strimzi特定的指
浏览 10提问于2020-03-06得票数 0
我使用Strimzi操作符在Kubernetes上部署了一个带有消费者和生产者客户端的kafka集群。我使用了以下strimzi部署文件https://github.com/strimzi/strimzi-kafka-operator/blob/main/examples/metrics/kafka-metrics.yaml 我正在使用Kafka exporter来监控与消费者相关的指标(每个主题每秒传入/传出的消息、消费者组的滞后、偏移量等)。但是，我感兴趣的是将Prometheus配置为抓取kafka_exporter指标"kafka_consumergroup_members“
浏览 102提问于2021-07-20得票数 0
回答已采纳
我正在使用strimzi操作符并在k8上运行kafka集群。我想使用Kafka Mirror Maker，我使用CRD yml部署了Kafka Mirror Maker，但我的KMM的pod处于crashLoopBack状态。我不知道问题是什么？这是我的Kafka MirrorMaker yml apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaMirrorMaker
metadata:
name: my-mirror-maker
spec:
version: 2.6.0
replicas: 1
consumer:
boo
浏览 48提问于2020-11-20得票数 0
对于社区来说，这是一个非常普遍的问题，特别是Kafka Strimzi Bridge的人，如果他们正在阅读这篇文章的话。 我正在尝试将他们的Apache Kafka HTTP Bridge实现为某个POC。文档非常非常糟糕，并且没有提供任何帮助。我真的只需要知道你是如何使用桥发布和消费Kafka主题的消息的。我已经开始了桥，但不知道其他任何东西，因为文档缺乏基本的示例。
浏览 20提问于2019-10-02得票数 1
我们有一个由3个节点组成的连接集群。我们需要连接集群信任库中的几个证书。我们已经以以下方式安装了这些证书。
...
spec:
tls:
trustedCertificates:
- certificate: ca.crt
secretName: my-cluster-cluster-ca-cert
- secretName: root-cer
certificate: RootCA.crt
- certificate: IntermediateCA.crt
secretName: inter-
浏览 4提问于2020-08-04得票数 0
回答已采纳
我使用Confluent的Kafka连接器将数据从Kafka汇到一个MinIO桶中。我在Kubernetes环境中使用io.confluent.connect.s3.S3SinkConnector。这是我当前的S3 Sink配置：
kafkaConnectSpec:
class: io.confluent.connect.s3.S3SinkConnector
config:
tasks.max: 1
topics: topic-name
s3.bucket.name: bucket
flush.size: 1
store.url: ht
浏览 10提问于2021-03-19得票数 0
回答已采纳
我正在使用带有strimzi运算符的Kafka。我不知道如何使用KafkaUser，有没有人可以建议我应该在哪里学习它的实际实现。我刚刚创建了一个Kafka用户和KafkaTopic，现在我完全不知道该怎么做。这是我的KafkaUSer yml代码： apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaUser
metadata:
name: my-user
labels:
strimzi.io/cluster: my-cluster
spec:
authentication:
type: tls
authoriza
浏览 48提问于2020-11-18得票数 0
回答已采纳
我是否可以删除多个CRDS，其名称包含与kubectl/bash一行相同的字符串？例如，我想删除以下所有内容：
kafkabridges.kafka.strimzi.io
kafkaconnectors.kafka.strimzi.io
kafkaconnects.kafka.strimzi.io
kafkamirrormaker2s.kafka.strimzi.io
kafkamirrormakers.kafka.strimzi.io
kafkarebalances.kafka.strimzi.io
kafkas.kafka.strimzi.io
kafkatopics.kafka.stri
浏览 6提问于2022-10-17得票数 0
我有一个简单的python Kafka生产者，我试图访问GKE上的Strimzi集群，我得到了以下错误：
cimpl.KafkaException: KafkaError{code=_INVALID_ARG,val=-186,str="Failed to create producer: ssl.key.location failed: error:0B080074:x509 certificate routines:X509_check_private_key:key values mismatch"}
以下是卡夫卡制片代码：
from confluent_kafka imp
浏览 6提问于2021-12-02得票数 0
回答已采纳
1回答
我想要访问我的卡夫卡集群使用nodeport.Here是我的CRD使用，我试图暴露卡夫卡使用nodeport。
apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
name: my-cluster
spec:
kafka:
version: 2.6.0
replicas: 3
listeners:
- name: plain
port: 9092
type: internal
tls: false
- name: tls
浏览 2提问于2020-11-23得票数 0
回答已采纳
我有一个正在运行的使用Strimzi cluster-operator的Kafka-zookeeper集群。为此，我遵循了KB 。可以从端口9404获取kafka和zookeeper的指标。我必须将这个集群设置配置到Prometheus以进行监控。Strimzi本身有一个用于配置普罗米修斯的知识库()。但我的问题是，我不能根据它们的KB配置集群，因为在我的Prometheus设置中，我必须配置service-monitor来发现应用程序，并且我需要在其服务中指定指标可用端口。但我找不到任何解决方案。请求帮助...
浏览 3提问于2018-09-23得票数 0
1回答
无法连接:通信链接失败
、、、、
我正在尝试遵循教程。根据本教程，我也使用迷你库，但与码头司机。基本上就是一步一步地走下去。
但是，对于步骤“创建连接器”，在创建连接器之后
cat <<EOF | kubectl -n kafka apply -f -
apiVersion: "kafka.strimzi.io/v1alpha1"
kind: "KafkaConnector"
metadata:
name: "inventory-connector"
labels:
strimzi.io/cluster: my-connect-cluster
spec
浏览 3提问于2021-09-29得票数 0
回答已采纳
我用下面的yaml设置了Strimzi集群。 apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
name: kafka
spec:
kafka:
replicas: 3
listeners:
- name: plain
port: 9092
type: internal
tls: false
- name: tls
port: 9093
type: internal
tls: tru
浏览 20提问于2021-08-17得票数 1
回答已采纳
我在AWS上运行的Rancher Kuberenetes环境中部署了Strimzi Operator。我使用Strimzi操作符用3个代理部署我的Kafka集群。我的集群运行良好，我可以进行生产和消费。现在我想使用Prometheus和Grafana来监控Kafka集群。我使用的是2.2.6版本的Rancher，所以它是随Prometheus和Grafana一起提供的，我想用它来进行监控。
我尝试了Strimzi运算符上的文档，但无法获得文档中提供的指标。我的Grafana仪表板显示为NA或0。事实上，我的Kafka集群运行的命名空间也没有显示u。您能否提供帮助，如何使用Rancher中内置的
浏览 15提问于2019-08-05得票数 0
使用CNCF的Strimzi Kafka Bridge，我创建了一个小API，它可以使用HTTP/1.1协议与Kafka服务器交互。这对于请求-响应场景来说是很好的。但是，我的要求是在收到Kafka主题上的事件时，立即将它们流式传输到订阅客户端(通过Strimzi桥)，最好是通过长时间的HTTP连接(根据我的理解)。不断轮询桥上的消息，然后空手而归，这是对客户端资源的浪费。我希望Kafka服务器将这些事件直接流到客户端。 我对SSE、Websockets或长轮询有点不确定。我对这些方法做了相当多的阅读，以便将数据流式传输到客户端。但是，我无法确定这些更改是在通信层还是在应用层，或者两者都有。
浏览 29提问于2019-10-05得票数 2
回答已采纳
我正在使用Strimzi，Kafka，Kafka Connect和一个自定义连接器插件，遵循。
部署工作正常，Kafka Connect工作正常，我可以使用它的RESTFUL API。
但是连接器没有创建。这是错误消息：
未能找到实现连接器且名称与org.company.MySourceConnector匹配的任何类
我知道原因:它找不到插件(一个jar文件)。但是如果我进入卡夫卡-连接荚，我可以看到右边的jar文件：/opt/kafka/plugins/my-source-connector/my-source-connector.jar。
此外，我运行cat /tmp/strimz
浏览 6提问于2021-12-10得票数 0
回答已采纳
2回答
我是新手，我试图为kafka生成不同的主题，其范围函数为每个主题都没有yaml文件：
我有不同的话题(topic1，topic2，topic3，.)它们唯一的区别是主题和名称在ms中的保留，有些主题有3600000，其他的有540000，这是我的值文件：
KafkaTopics:
shortRetentionTopics:
name:
- topic1
- topic2
- topic3
- topic4
spec:
config:
retention.ms: 540000
topicName:
浏览 11提问于2022-04-28得票数 0
回答已采纳
我正在尝试与Strimzi一起创建kafka-connect集群，并遇到以下错误
unable to recognize "kafka-connect.yaml": no matches for kind "KafkaConnect" in
version "kafka.strimzi.io/v1beta2"
这是卡夫卡连接，我有：
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
name: kafka-connect
namespace: connect
浏览 11提问于2022-11-07得票数 1
回答已采纳
我是一个新的kafka空间，我在Kubernetes中安装了Strimzi集群运算符、Kafka引导服务器、实体操作符和kafka connect，遵循以下准则：
如何为strimzi kafka连接集群设置kafka mongo接收器连接器？
我有官方的mongodb连接器插件。我能用这个插件连接到地图集mongodb吗？
大多数论坛都对融合的卡夫卡进行了解释，但没有对卡夫卡进行解释。
下面是我的kafka连接配置：
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
name: my-mongo-c
浏览 16提问于2022-09-22得票数 0
我为Kafka和启用的TLS/ACL部署了Strimzi运算符，现在我卡住了！如何在用户创建的9093上运行producer.sh/consumer.sh？
以下是使用端口9092上禁用的ACL的命令：
kubectl -n myproject run kafka-producer -ti --image=strimzi/kafka:0.14.0-kafka-2.3.0 --rm=true --restart=Never -- bin/kafka-console-producer.sh --broker-list my-cluster-kafka-bootstrap:9092
但是如果我在上面
浏览 65提问于2020-04-15得票数 0
谁能列出在GKE中从头开始安装带有strimzi运算符的Kafka所需的步骤。 我们在其中一个虚拟机上安装了confluent kafka。我们必须从零开始在GKE环境中删除并安装strimzi kafka，所有涉及的步骤都是什么。 浏览本文档：https://strimzi.io/docs/operators/in-development/full/deploying.html 如果有任何其他步骤，文档或程序将有所帮助。
浏览 23提问于2021-08-27得票数 0
回答已采纳
我已经在kubernetes上部署了strimzi 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 --bro
浏览 32提问于2020-08-24得票数 0
我正在研究strimzi kafka，我想使用由证书经理颁发的自签名证书来部署kafka，而不是strimzi操作员/kafka提供了自签名证书。我已经看过strizmi文档，但是我没有找到将cert管理器与strimzi kafka/操作符集成的解决方案。当我们部署kafka时，我们可以看到在namespace.If中创建了许多秘密(带有证书)，我希望证书经理发布的所有机密/证书都能与kafka一起工作。
谢谢!！
浏览 5提问于2022-03-02得票数 0
我尝试在Kubernetes集群中使用Strimzi (0.14)构建一个Kafka集群。
我使用strimzi附带的示例，即examples/kafka/kafka-persistent.yaml。
此yaml文件如下所示：
apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
name: my-cluster
spec:
kafka:
version: 2.3.0
replicas: 3
listeners:
plain: {}
tls: {}
config:
浏览 1提问于2019-11-01得票数 0
我使用strimzi-0.26.0布署
cluster-source和cluster-target使用kafka版本是2.7.0
mirrormaker版本是2.7.0
通过mirrormaker从cluster-source的topicA复制到cluster-target，如何判断复制进度根据
是根据消费组偏移量查询吗？目前两个集群都没有消费组
复制前
cluster-source集群有1个topic
topicA
cluster-target集群没有topic
复制后
cluster-source集群有两个topic
topicA
mm2-offset-sy
浏览 246提问于2022-02-10
1回答
我已经配置了一个带有Strimzi的Kafka集群。我启用了tls身份验证，并使用NodePort公开了该服务。
在此之后，我已经导出了我的ca和我的密码，以生成一个JKS连接到Kafka。但问题是我有了下一个错误：
java.security.cert.CertificateException:没有与IP地址匹配的主题可选名称172.26.195.44
若要导出密码和ca：
kubectl get secret kafka-cluster-cluster-ca-cert -o jsonpath='{.data.ca\.crt}' | base64 --decode >
浏览 2提问于2022-02-13得票数 0
我已经成功地在OpenShift上建立了斯特里齐卡夫卡集群。我可以看到以下服务：
kafka-brokers
kafka-bootstrap
zookeeper-client
zookeeper-nodes
这实际上不同于所谓的；因此，不确定这是否是Strimzi安装问题。我遵循了的安装步骤。
我在端口kafka-bootstrap (非TLS客户端)上为kafka-brokers和9092创建了一个路由。在这两种情况下，当我提供路由值(例如，来自ECONNREFUSED的示例中的my-cluster-myproject.192.168.99.100.nip.io:90
浏览 3提问于2019-10-03得票数 1
回答已采纳
1回答
我正在使用KafkaCluster在K8s上部署KafkaConnect。
Strimzi算子集群图像:quay.io/strimzi/运算符:0.26.1
卡夫卡图像: quay.io/strimzi/ Kafka :0.26.1-kafka-3.0.0。
我正在尝试设置连接到Postgres的KafkaConnector。
以下是我的步骤：
从这个图像‘quay.io/strimzi/kafka:0.26.1-Kafka3.0.0’构建一个新的KafkaConnect。这个新的图片有插件，我从这个链接'‘下载
我在K8s上运行这个新映像，然后执行到K
浏览 7提问于2021-12-22得票数 0
4回答
我有一个kubernetes集群运行在多台本地(裸金属/物理)机器上。我想在集群上部署kafka，但我不知道如何在配置中使用strimzi。
我试着遵循快速入门页面上的教程：
我的动物园管理员吊舱正在2.4. Creating a cluster点等待：
Events:
Type Reason Age From Message
---- ------ ---- ---- -------
Warning FailedScheduling &
浏览 18提问于2020-01-07得票数 0
回答已采纳
2回答
我正在使用带有strimzi操作符的Kafka，我创建了一个Kafka集群，并使用yml文件部署了Kafka连接。但在这之后，我完全不知道下一步该做什么。我了解到Kafka connect用于将数据从源复制到Kafka集群，或者从Kafka集群复制到另一个目标。我想使用Kafka connect将文件中的数据复制到Kafka集群的any主题。谁能帮助我，我怎么做，我正在分享的yml文件，我用来创建我的Kafka连接集群。
apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaConnect
metadata:
name: my-connect
浏览 4提问于2020-11-20得票数 2
这就是我的docker-compose.yml文件
version: '3.2'
services:
elasticsearch:
build:
context: elasticsearch/
args:
ELK_VERSION: $ELK_VERSION
volumes:
- type: bind
source: ./elasticsearch/config/elasticsearch.yml
target: /usr/share/elasticsearch/config
浏览 16提问于2021-02-17得票数 0
回答已采纳
我们知道如何将Kafka属性authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer添加到server.properties中，但是如果Kafka集群是由Strimzi运算符运行的，那么如何启用它呢？
从我所了解的Strimzi文档中，为了启用授权，需要在规范下为kind: Kafka启用下面的代码：
listeners:
tls:
authentication:
type: tls
完整代码@
也是下面的kind: KafkaUser代码
authentication:
浏览 0提问于2020-04-05得票数 2
回答已采纳
1回答
我已经使用Strimzi在Kubernetes上配置了一个Kafka集群。使用本文- ，但我公司的安全服务不希望使用自签名证书在UAT中部署此解决方案。您能告诉我，我可以将我们的信任证书从一个可信的冲浪中心导入到这个Kafka解决方案中吗？
我将此部分添加到我的yml文件中，引用密钥配置: brokerCertChainAndKey: secretName: es-kafka- 证书: certificate.crt密钥: certificate.key
但是当我测试的时候我出错了
[thrd:ssl://104.42.195.73:9094/bootstrap]: ssl://104.42.
浏览 3提问于2021-04-15得票数 0
嘿我是卡夫卡·斯特里齐。我使用以下yml文件创建了我的kafkaTopic和KafkaUser：
apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaUser
metadata:
name: my-user
labels:
strimzi.io/cluster: my-cluster
spec:
authentication:
type: tls
authorization:
type: simple
acls:
# Example consumer Acls for topic my-to
浏览 2提问于2020-11-17得票数 0
回答已采纳
我在GKE上使用strimzi操作符0.15版部署了Kafka，并且运行良好。配置如下：
kafka:
version: 2.3.1
replicas: 3
config:
offsets.topic.replication.factor: 3
transaction.state.log.replication.factor: 3
transaction.state.log.min.isr: 2
log.message.format.version: "2.3"
当我对kubernetes集群进行升级时
浏览 2提问于2021-10-13得票数 0
我们有三个副本的MongoDB集群。我已经启用了首选的TLS和身份验证类型为MongoDB 509。
我们有三个代理strimzi kafka集群，并将集群与所有所需的插件(即debezium提供的mongoDB )连接起来并运行。
下面提供了用于kafka连接部署的部分connect.yaml文件：-
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
name: my-connect
spec:
config:
config.providers: directory
config.pro
浏览 9提问于2021-12-23得票数 1
1回答
我在kubernetes上运行kafka (部署在Azure上)，使用strimzi作为开发环境，我更喜欢使用内部kubernetes节点存储。如果我使用persistant claim，它会在天蓝色存储上创建标准磁盘。然而，我更喜欢使用内部节点存储，因为我在那里有16 gb可用。我不想使用短暂的数据，因为我希望数据被持久化，至少在kubernetes节点上。折叠是我的deployment.yml
apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
name: kafka-cluster
spec:
kafka:
浏览 5提问于2022-03-01得票数 0
我按照下面的链接在k8s中创建了strimzi集群运算符 https://medium.com/@sincysebastian/setup-kafka-with-debezium-using-strimzi-in-kubernetes-efd494642585 下载strimzi 0.17.0版本并解压缩。我运行了Kubectl apply -f apply install/cluster-operator。我得到错误“检测版本失败”，它的套接字连接超时。 为了解决这个问题，我在集群运算符conf文件中添加了STRIMZI_KUBERNETES_VERSION。现在我收到"Detec
浏览 55提问于2020-04-12得票数 0
我需要将Strimzi巡航控制默认主题(模型训练样本、分区度量样本)复制因子增加到3，在下面的配置中尝试它，但是它不起作用。
apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
name: my-cluster
spec:
kafka:
version: 3.3.1
replicas: 3
listeners:
- name: plain
port: 9092
type: internal
tls: false
- name: tls
浏览 12提问于2022-11-28得票数 0
回答已采纳
我有个奇怪的问题没人能找出来。为了确保这不是Azure Kubernetes的问题，我还设计了小型库来在本地进行测试，我也得到了同样的错误。对于MirrorMaker2来说，最常见的一件事是Strimzi 0.28。
您可以在这里阅读整个线程，以防有帮助。我们被困在死胡同了。链接到整个讨论是github下的strimzi；
。
我移动它，因为我不想垃圾邮件作为一个名为学者的绅士，帮助和提供了一些伟大的建议。但似乎什么都起不到作用。
这就是我所做的。
创建秘密
将实际数据替换为，用于投递。
cat <<EOF | kubectl apply -n kafka-cloud
浏览 6提问于2022-03-17得票数 0
回答已采纳
我们正在使用Strimzi来管理Kubernetes中的Kafka集群。
下面是我们的Kafka集群的Strimzi配置(删除了下面的SSL和授权混淆)：
[kafka@k8s-kafka-2 kafka]$ cat /tmp/strimzi.properties
##########
# User provided configuration
##########
log.message.format.version=2.6
log.retention.hours=-1
offsets.retention.minutes=525600
offsets.topic.replication.fa
浏览 2提问于2021-12-30得票数 0
我对fabric8io 的使用有一个问题。
我想要的:在Kubernetes中用Strimzi运算符创建Kafka集群。如果我用CLI和kubectl完成了从到kubectl的所有步骤，这都很好。
但是，当我用kubernetes-client:5.2.1代码加载yaml资源时，会出现异常：
io.fabric8.kubernetes.client.KubernetesClientException: An error has occurred.
at io.fabric8.kubernetes.client.KubernetesClientException.launderThrowab
浏览 31提问于2021-03-18得票数 1
回答已采纳
我正在尝试寻找是否有可能水平缩放一个strimzi kafka连接集群，以利用pod/节点自动标度，因为我有一个巨大波动的生产负载。
我尝试过将hpa配置应用到最终的kafka连接部署中，但随着新荚的启动和迅速死亡，它似乎与kafkaconnect副本定义相冲突。我假设有一些strimzi机制可以将部署大小与kafkaconnect清单同步，从而阻止hpa工作。
有人知道这是否可能吗？
浏览 5提问于2022-01-26得票数 1
回答已采纳
我使用strimzi操作符(版本为0.28.0)创建了一个kafka集群，设置如下：
spec:
kafka:
config:
log.retention.hours: 5
auto.create.topics.enable: false
default.replication.factor: 3
min.insync.replicas: 2
假设不会自动创建主题，我添加了两个主题定义：
模式注册表的_schemas
面向消费者群体的__consumer_offsets
但是，在启动集群之后，我还看到了两个自动创建的主
浏览 25提问于2022-02-15得票数 0
回答已采纳
我试图从一个logstash码头容器连接到kafka码头集装箱，但我总是收到以下消息：
Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
我的docker-compose.yml文件是
version: '3.2'
services:
elasticsearch:
build:
context: elasticsearch/
args:
ELK_VERSION: $EL
浏览 1提问于2019-10-11得票数 3
回答已采纳
我已经安装了Strimzi Kafka和带有TLS侦听器的Kafka集群(如果重要的话，在OpenShift中)。当我添加KafkaUser时，我会像这样请求TLS身份验证：
spec:
authentication:
type: tls
authorization:
type: simple
然后，我提取由Strimzi用户的密钥库创建的内容，并在从客户端代码连接到Kafka bootstrap服务器时提供它。
问:如何在添加KafkaUser时提供自定义SSL证书，或者是否有方法将自动生成的SSL用户证书替换为自定义证书(例如延长有效期)？特别是，将用户证书添加到哪
浏览 17提问于2021-03-18得票数 0
在AKS中设置一个简单的Strimzi集群时，当代理程序需要删除/清除日志文件时，我遇到了一个问题。此问题仅在使用azurefile存储类时发生，但与其他类一起工作很好。
在具有一个代理和一个动物园管理员副本的集群上进行复制的步骤。删除主题会触发代理结束符中的错误。当日志清理程序试图运行具有“紧凑”策略的主题时，也会出现问题。
Strimzi群集设置
apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
name: test-cluster
namespace: kafka-test
spec:
kafka:
浏览 6提问于2022-07-19得票数 0
回答已采纳
我有一个关于Kubernetes中的Kafka的问题，特别是自动缩放...
假设我在Kubernetes的3个Pod中有3个Kafka Broker，有一个带有5个分区(P1，P2，P3，P4，P5)的TopicA，复制因子是3，所有的Broker都有他们的持久卷，我在Kubernetes中配置了自动扩展，所以如果它检测到Kafka Pods中的%80CPU/内存使用率，它将为Kafka Broker启动额外的Pod...
如果我没有完全错的话，Kafka会检测到Zookeeper上的额外实例，并可以移动分区(所以假设P1，P2在Broker1和P3，P4在Broker2，P5在Broker3
浏览 5提问于2019-11-06得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
