在OpenShift上安装了路由监听器类型的Strimzi Kafka中可以访问Zookeeper吗？
在OpenShift上安装了路由监听器类型的Strimzi Kafka，可以通过路由监听器访问Zookeeper。
Strimzi是一个开源的Kafka运算符，用于在Kubernetes和OpenShift上部署和管理Kafka集群。它提供了一种简化的方式来部署和管理Kafka，同时还提供了一些额外的功能和扩展性。
在Strimzi Kafka中，Zookeeper是Kafka集群的关键组件之一，用于存储和管理Kafka的元数据和状态信息。Zookeeper负责协调Kafka集群中的各个节点，并提供高可用性和容错性。
通过在OpenShift上安装路由监听器类型的Strimzi Kafka，可以使用OpenShift的路由功能来实现对Kafka集群中的Zookeeper的访问。路由监听器允许外部客户端通过OpenShift的路由器访问Kafka集群中的服务。
具体来说，可以通过以下步骤来访问Strimzi Kafka中的Zookeeper：
- 在OpenShift上安装和配置Strimzi Kafka集群，确保Zookeeper组件已正确部署和运行。
- 创建一个路由监听器，将其配置为路由到Kafka集群中的Zookeeper服务。可以使用OpenShift的命令行工具或Web界面来创建和配置路由监听器。
- 使用路由监听器的URL来访问Kafka集群中的Zookeeper。可以使用任何支持Zookeeper协议的客户端工具或库来进行访问。
需要注意的是，具体的配置和访问方式可能会因部署环境和需求而有所不同。建议参考Strimzi Kafka和OpenShift的官方文档以获取更详细的配置和使用说明。
推荐的腾讯云相关产品：腾讯云容器服务（Tencent Kubernetes Engine，TKE）。腾讯云容器服务是基于Kubernetes的容器管理服务，提供了一站式的容器化解决方案，可用于部署和管理Strimzi Kafka集群以及其他容器化应用。详情请参考腾讯云容器服务官方文档：https://cloud.tencent.com/product/tke
相关·内容
我已经成功地在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
回答已采纳
我在OpenShift上有Strimzi Kafka集群，配置如下： https://strimzi.io/blog/2019/04/30/accessing-kafka-part-3/ 基本上是这样的： kind: Kafka
metadata:
name: ...
spec:
kafka:
version: 2.7.0
replicas: 2
listeners:
plain: {}
tls:
authentication:
type: tls
external:
ty
浏览 67提问于2021-03-20得票数 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
回答已采纳
4回答
我有一个kubernetes集群运行在多台本地(裸金属/物理)机器上。我想在集群上部署kafka，但我不知道如何在配置中使用strimzi。
我试着遵循快速入门页面上的教程：
我的动物园管理员吊舱正在2.4. Creating a cluster点等待：
Events:
Type Reason Age From Message
---- ------ ---- ---- -------
Warning FailedScheduling &
浏览 18提问于2020-01-07得票数 0
回答已采纳
1回答
大家好！
主要问题是:我想通过自己的清单从本地机器连接到运行在k8s容器中的集群( DNS node03.st)上的Kafka。
动物园管理员部署清单如下(图：confluentinc/cp-zookeeper:6.2.4)：
---
apiVersion: apps/v1
kind: Deployment
metadata:
namespace: aptmess
name: zookeeper-aptmess-deployment
labels:
name: zookeeper-service-filter
spec:
selector:
matchLabel
浏览 4提问于2022-06-16得票数 0
1回答
我正在尝试使用这种方法将Kafka部署到Openshift：
部署设置好了，我可以在容器中设置一个代理和消费者，它们工作得很好。当我尝试使用控制台-消费者(使用端口转发到我的本地机器)访问一个主题时，我得到一条消息，告诉我代理不可用。
我尝试将advertised.listeners=PLAINTEXT://openshiftRoute:80覆盖添加到yaml文件，但现在我得到的是Error while fetching metadata with correlation id X : {test=LEADER_NOT_AVAILABLE}。
当我尝试使用到localhost的Openshif
浏览 0提问于2019-05-15得票数 0
1回答
我一直试图在Openshift集群之外访问我的Kafka代理，但它不允许我访问。我已经设置了所需的Openshift路径，并将其指向我的kafka服务。我试着在互联网上查看它，但是每次我都有一篇文章指向strimzi运营者/ AMQ运算符来实现这一功能。我现在在想，比特尼卡夫卡到底支持还是不支持路线？我找不到关于这件事的任何文件。有人能帮我指出正确的方向吗？
浏览 11提问于2022-11-18得票数 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
1回答
跟随和使用GKE内部负载均衡器与Strimzi。在添加内部负载均衡器之后，Strimzi提供了两个带有外部IP的负载均衡器服务。
Kafka % k get svc -n kafka
NAME TYPE CLUSTER-IP EXTERNAL-IP PORT(S) AGE
my-cluster-kafka-0 LoadBalancer xx.xxx.xx.xxx bb.bb.bbb.bb
浏览 14提问于2022-09-24得票数 0
回答已采纳
我已经安装了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
嘿我是卡夫卡·斯特里齐。我使用以下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
回答已采纳
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
回答已采纳
这就是我的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
回答已采纳
1回答
我正在尝试使用Strimzi提供对Kafka的双向外部访问，遵循以下指南：Red Hat Developer - Kafka in Kubernetes 我的YAML摘自Strimizi examples on GitHub，如下所示： apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
name: my-cluster
spec:
kafka:
version: 3.0.0
replicas: 1 #3
listeners:
- name: plain
port:
浏览 135提问于2021-10-28得票数 0
回答已采纳
2回答
Strimzi -连接外部客户端
、、、、
在讨论之后，我使用以下步骤来启用外部客户端(基于)连接到OpenShift上的Strimzi。这些步骤来自。
启用外部路由
将kafka-persistent-single.yaml编辑为，如下所示。
apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
name: my-cluster
spec:
kafka:
version: 2.3.0
replicas: 1
listeners:
plain: {}
tls: {}
external:
浏览 0提问于2019-10-05得票数 1
1回答
我们的问题是内部属性kafka.bootstrap.servers不会被kafka:9092覆盖。我们的容器仍然试图访问localhost:9092。
我们在docker-compose.yml文件中将每个微服务的环境设置为: kafka.bootstrap.servers=kafka:9092，并且每个MS的属性也是相同的。
有什么方法可以覆盖这个属性吗？
编辑:我们的docker-compose.yml文件的重要部分：
services:
zookeeper:
image: strimzi/kafka:0.19.0-kafka-2.5.0
command:
浏览 11提问于2021-06-02得票数 0
回答已采纳
我有一个正在运行的使用Strimzi cluster-operator的Kafka-zookeeper集群。为此，我遵循了KB 。可以从端口9404获取kafka和zookeeper的指标。我必须将这个集群设置配置到Prometheus以进行监控。Strimzi本身有一个用于配置普罗米修斯的知识库()。但我的问题是，我不能根据它们的KB配置集群，因为在我的Prometheus设置中，我必须配置service-monitor来发现应用程序，并且我需要在其服务中指定指标可用端口。但我找不到任何解决方案。请求帮助...
浏览 3提问于2018-09-23得票数 0
我试图在运行在Windows 10上的本地munikube集群上安装带有Strimzy的Kafka，以测试不同参数(特别是TLS配置)的影响。在迁移到TLS之前，我只想连接到集群:)
以下是我的yaml配置：
apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
name: my-cluster
spec:
kafka:
version: 2.3.0
replicas: 1
listeners:
external:
type: nodeport
tls:
浏览 8提问于2022-04-29得票数 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巡航控制默认主题(模型训练样本、分区度量样本)复制因子增加到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
回答已采纳
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
我正在部署一个卡夫卡集群在库伯内特斯使用斯维齐卡夫卡运算符。我需要能够使用Jolokia通过HTTP/REST远程查询Kafka (Jolokia是一个转换和公开用于查询HTTP…的JMX度量的代理)。
AFAIK，Strimzi文档没有提供关于如何将Jolokia附加到kafka经纪人的任何提示。因此，请提供一个提示，说明如何修改部署文件(strimzi操作符和/或集群部署文件)，以便将Jolokia附加到代理/Zookeeper实例。
浏览 17提问于2022-05-09得票数 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
1回答
我目前正面对一种我无法真正抓住的奇怪行为。
我创建了一个卡夫卡集群，一切都很好。然后我想要在不同的名称空间上重建，所以我删除了所有东西(kafka CRD、strimzi yaml和设备)，并在不同的名称空间中创建了所有新的东西。
现在，我收到了不断的错误消息(kafka没有启动)：
The Cluster ID oAF2NGklQ0mF2_f3U0oJuw doesn't match stored clusterId Some(Gjb2frSRSS-v6Bpjx-dyqg) in meta.properties. The broker is trying to join the wr
浏览 7提问于2022-03-21得票数 0
谁能列出在GKE中从头开始安装带有strimzi运算符的Kafka所需的步骤。 我们在其中一个虚拟机上安装了confluent kafka。我们必须从零开始在GKE环境中删除并安装strimzi kafka，所有涉及的步骤都是什么。 浏览本文档：https://strimzi.io/docs/operators/in-development/full/deploying.html 如果有任何其他步骤，文档或程序将有所帮助。
浏览 23提问于2021-08-27得票数 0
回答已采纳
2回答
我试图用strimzi部署kafka，问题是，它将kafka代理暴露为负载平衡器，并分配给他们一个外部IP。我想卡夫卡经纪人可以在内部和暴露通过一个负载平衡器只。下面是我的部署文件。
apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
name: my-cluster
spec:
kafka:
version: 3.1.0
replicas: 2
listeners:
- name: plain
port: 9092
type: internal
浏览 4提问于2022-04-29得票数 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
回答已采纳
我用下面的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
回答已采纳
我有一个码头组成的群与动物园管理员服务启动良好，但卡夫卡服务不能启动。
它一直使用默认的KAFKA_ADVERTISED_LISTENERS属性：
debezium_kafka.1.5hhrqfp5kqts@stephane-pc | Using ZOOKEEPER_CONNECT=zookeeper:2181
debezium_kafka.1.5hhrqfp5kqts@stephane-pc | Using KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://10.0.83.239:9092
当然，它也找不到映射中指定的侦听器：
debezium_kaf
浏览 0提问于2020-10-20得票数 1
我有下面的docker compose yml， version: '3.5'
services:
zookeeper:
container_name: kafka-zookeeper
image: wurstmeister/zookeeper:3.4.6
ports:
- "2181:2181"
networks:
- my-network
kafka:
container_name: kafka-server
image: wurstmeister/kafka:2.12-2
浏览 21提问于2020-09-06得票数 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
1回答
我已经设置了一个Kafka集群，其中我指定了这样的代理：
kafka1:
image: confluentinc/cp-kafka:latest
hostname: kafka1
ports:
- "19092:19092"
depends_on:
- zookeeper-1
- zookeeper-2
- zookeeper-3
environment:
KAFKA_BROKER_ID: 1
KAFKA_ZOOKEEPER_CONNECT: zookeeper-1:
浏览 1提问于2020-03-21得票数 1
回答已采纳
我已经创建了一个卡夫卡集群使用斯特里齐卡夫卡运算符的迷你库贝学习基础。我正试图从我的主机进入Kafka的迷你库环境，为此我创建了一个Kafka节点端口：
apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
name: kafka-cluster
spec:
kafka:
version: 2.4.0
replicas: 3
listeners:
plain: {}
tls: {}
external:
type: nodeport
浏览 2提问于2020-04-03得票数 0
回答已采纳
4回答
我使用以下docker-compose.yml运行了一个本地kafka
version: '2'
services:
zookeeper:
image: "confluentinc/cp-zookeeper:5.0.1"
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
kafka:
image: "confluentinc/cp-enterprise-kafka:5.0.1"
ports:
浏览 80提问于2018-12-03得票数 26
回答已采纳
我在GKE上有一个Strimzi集群，我也部署了kafkaExporter。Kafka主题有acls，并且定义了一个消费者组(Spark-KafkaSource-*)，它可以从主题中读取数据。
我正在运行一个火花StructuredStreaming程序，它从卡夫卡主题中读取数据。问题是-当我检查指标KafkaExporter -> kafka_consumergroup_lag时，似乎没有向消费者组显示
消费者组出现在米制: kafka_consumergroup_members ->中。
kafka_consumergroup_members{consumergroup=
浏览 4提问于2022-08-22得票数 0
回答已采纳
我有两组，
一个集群安装了我的应用程序Microservices，另一个集群安装了strimzi kafka。两者都是私有的GKE集群。
我的挑战恰恰是如何从我的应用程序中连接到这个kafka。有大约10个微服务运行，每个必须连接到卡夫卡。
现在，我有了一种方法，将Strimzi作为Nodeport服务，并在应用程序代码中提供Ip和nodeIp。
这种方法的问题是，如果GKE节点自动更新，我将不得不重新配置代码。
还有一个更关键的条件是，卡夫卡只能通过我们的应用程序访问，它不应该在公共互联网上使用。
浏览 0提问于2021-09-13得票数 0
回答已采纳
1回答
Apache可用于库伯内特斯和OpenShift的RedHat(AMQ )。RedHat的AMQ流是基于斯特里齐的卡夫卡运营者。
但是，当您定义Kafka资源(如经纪人或主题)时，您的YAML开始时如下所示
apiVersion: kafka.strimzi.io/v1beta1
它清楚地写着beta1，这意味着它还没有准备好生产。
我应该在我的Kubernetes/Openshift集群上使用Strimzi的Kafka操作符吗？或者还有别的选择吗？
浏览 1提问于2020-11-20得票数 0
回答已采纳
我是一个新的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
我尝试在之后，在docker-desktop k8s上运行strimzi。
我把所有的东西都安排好了。
$ kubectl get all -n my-kafka-project
NAME READY STATUS RESTARTS AGE
pod/my-cluster-entity-operator-7ddb6d5b88-q2xg8 3/3 Running 0 97m
p
浏览 37提问于2021-05-15得票数 1
我设置了一个docker-compose.yaml
version: '3'
services:
zookeeper:
image: zookeeper:latest
restart: unless-stopped
ports:
- "2181:2181"
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
kafka:
image: ligato/kafka-arm64
ports
浏览 23提问于2021-05-30得票数 0
我是Kubernetes的新手，正在尝试在单节点minikube集群上部署单个副本kafka实例。
下面是zookeeper服务/部署yml
apiVersion: v1
kind: Service
metadata:
name: zookeeper-cluster
labels:
component: zookeeper
spec:
ports:
- name: "2181"
port: 2181
targetPort: 2181
selector:
component: zookeeper
status:
loadBa
浏览 1提问于2020-08-31得票数 0
1回答
我已经为我的基于spring boot的库配置了以下Kafka属性，这些库捆绑在部署到Wildfly的EAR的lib目录中。通过从类路径加载porperty文件(WEB-INF/classes)，我能够成功地启动spring组件。 spring.autoconfigure.exclude=org.springframework.boot.autoconfigure.gson.GsonAutoConfiguration,org.springframework.boot.autoconfigure.jms.artemis.ArtemisAutoConfiguration,\
org.spring
浏览 102提问于2021-04-28得票数 1
回答已采纳
当我尝试使用这个部署一个卡夫卡节点时，我正在本地机器上玩开放式转换，但是我得到了这个异常：
我不知道发生了什么，卡夫卡成功地与动物园管理员交谈，我可以在这个日志中看到，但在那之后，这个例外，明显不够，我的意思是，卡夫卡试图写的地方？哪个用户正在尝试编写？
[2017-05-24 13:06:28,835] INFO Opening socket connection to server zookeeper.myproject.svc.cluster.local/172.30.106.154:2181. Will not attempt to authenticate using SASL (u
浏览 2提问于2017-05-24得票数 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
回答已采纳
当我在本地的机器上把卡夫卡旋转起来的时候，我就能让卡夫卡工作得很好。但是，当我试图让它在AWS实例上工作时，似乎没有什么是正确的。我试着旋转我自己的服务器，就像我在本地旋转动物园管理员和卡夫卡一样
curl http://apache.spinellicreations.com/kafka/0.10.0.0/kafka_2.11-0.10.0.0.tgz | tar -xzf
cd kafka_2.11-0.10.0.0
bin/zookeeper-server-start.sh config/zookeeper.properties &
bin/kafka-server-st
浏览 2提问于2016-10-20得票数 2
回答已采纳
2回答
我在docker中运行Kafka，我有一个.NET应用程序，我想使用它来使用消息。我在没有运气的情况下遵循了下面的教程：
在我的使用者应用程序中，如果我试图直接连接到容器ip，我会得到以下错误：
172.21.0.3:9092/bootstrap: Connect to ipv4#172.21.0.3:9092 failed: Unknown error (after 21502ms in state CONNECT)
Error: 1/1 brokers are down %3|1620652406.633|FAIL|rdkafka#consumer-1| [thrd:172.21.0
浏览 18提问于2021-05-10得票数 1
回答已采纳
我使用的是Confluent.Kafka，我得到了以下错误：
配置属性sasl.mechanism设置为PLAIN，但security.protocol未为SASL配置:建议将security.protocol设置为SASL_SSL或SASL_PLAINTEX T
我该怎么解决呢？为了更方便，这个项目是在上进行的。
appsettings.json
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft&
浏览 12提问于2022-09-20得票数 1
我正在开发一个应用程序，它从sqs队列中读取消息，对这些数据做一些处理，并将结果发布到kafka主题。为了在本地进行测试，我想在我的码头建造中设置一个卡夫卡图像。目前，我能够在本地使用docker旋转aws、local堆栈和我的应用程序的容器。另外，我也可以毫无问题地旋转卡夫卡和动物园。我无法得到我的申请与卡夫卡沟通。
我试过使用两个独立的撰写文件，并且还篡改了网络。最后，我引用了：。
这是我的停靠-撰写文件：
version: '3.7'
services:
localstack:
image: localstack/localstack:latest
c
浏览 0提问于2019-07-18得票数 0
回答已采纳
我在码头上安装了卡夫卡和下面的yml
version: "3"
services:
zookeeper:
image: 'bitnami/zookeeper:latest'
ports:
- '2181:2181'
environment:
- ALLOW_ANONYMOUS_LOGIN=yes
kafka:
image: 'bitnami/kafka:latest'
ports:
- '9092:9092'
- '9093:9093'
environment:
- KAF
浏览 9提问于2022-04-28得票数 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备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
