我想在Kubernetes环境上部署Kafka集群，并让Kubernetes集群中的服务以SASL_PLAINTEXT模式连接到Kafka，而Kubernetes集群之外的服务以SASL_SSL模式连接到Kafka。然而，我发现在设置之后，外部服务无法连接到Kafka。卡夫卡不允许内部服务以不同的方式连接到外部服务吗？我的卡夫卡版本是2.3.1，如果你能回答我的问题，我将不胜感激。
浏览 4提问于2022-08-13得票数 0
我在一个kubernetes集群中有一个python快速app应用程序和kafka，但是在不同的名称空间中。Python应用程序生成从客户端到kafka主题的消息。首先，在python脚本中，我试图以以下方式连接kafka broker： bootstrap_servers=os.environ["KAFKA_SERVER=lambda v: v.encode('utf-8')KAFK
浏览 14提问于2022-10-17得票数 0
我在我的mac上的minikube k8集群的Pod上运行了一个landoop kafka镜像。我有两个不同的服务来公开用于模式注册的端口8081和用于代理的端口9092。我已经在我的NodePort服务中映射了端口8081 -> 30081和9092 -> 30092，以便我可以从集群外部访问它。但是，当我尝试运行控制台消费者或我的消费者应用程序时，Kafka从不消费消息。1)不能在k8集群之外通过上述方式访问k8集群外的Kafka吗?如果是这样，我是不是
浏览 86提问于2018-02-13得票数 3
我正在尝试连接到Kafka集群。测试命令为：我可以通过telnet但是，连接例外情况是：
[2020-03-03 16:53:53,784] WARN [Consumer clientId=consumer-console-consumer-11138-1, groupId(org.apache.kafka</e
浏览 29提问于2020-03-03得票数 0
回答已采纳
我们的集群是托管的。每次创建内部主题时，我们都必须要求管理员解锁，这样kafka流应用程序才能创建内部主题。我们可以控制目标群集，而不是源群集。
那么，想要了解内部主题创建了哪些群集源/目标吗？
浏览 22提问于2020-09-17得票数 1
Kafka，不管怎样，都需要三个内部主题:配置、偏移和状态。这些主题是否应该存在于我正在消费数据的Kafka集群中？就上下文而言，我正在做的是其他人设置了一个Kafka集群，其中包含主题(消息？)我在我的本地机器上旋转了一个Kafka集群(用于测试)和这个本地实例(我们将称之为向前)，然后通过键入引导服务器、一些回调处理程序类和一个connect.jaas文件，连接到远程Kafka集群(我们将称之为
浏览 2提问于2021-12-10得票数 0
回答已采纳
environment: KAFKA_ADVERTISED_HOST_NAME: kafkaKAFKA_ADVERTISED_PORT: 9092 KAFKA_CREATE_TOPICS:572)
kafka_1 |
浏览 257提问于2019-06-23得票数 1
要在本地mac中运行cps3连接以使用kafka主题，我做了如下操作ML-C02Z605SLVDQ:kafka_2.12e192270$ cd kafka_2.12-2.5.0
ML-C02Z605SLVDQ:kafka_2.12-2.5.0 e192270$ bin/connect-stand
浏览 3提问于2020-05-23得票数 1
我使用以下配置将我的自定义连接器部署在kafka- connector中并注册： "name" : "rabbitmq-source-connector", "internal.value.converter": "org.apache.kafka.connect.json.JsonConverter"它运行得很好，但是当我们重新启动kafka-conne
浏览 0提问于2021-10-08得票数 0
回答已采纳
1回答
但是，我不能从启动连接，也许是因为我需要提供的安全证书？我已经尝试将引导属性设置为：获取错误:在身份验证期间终止到节点-1 (/xx.xx:9092)的连接。这可能是由于以下任何原因造成的：(1)身份验证失败是由于代理的凭据无效，代理的年龄超过1.0.0；(2)防火墙阻塞Kafka TLS通信量(例如，它可能只允许HTTPS通信)；(3)瞬态网络问题。spring.kafka.properties.se
浏览 2提问于2020-03-02得票数 1
我正在将Kafka连接器从ECS集群迁移到运行在Kubernetes上的新集群。通过删除Postgres源连接器并在精确的复制槽上重新创建它们，我成功地迁移了Postgres源连接器。但是现在要移动AWS s3接收器连接器，我首先在新集群中创建了一个非关键的s3连接器，其名称与旧集群中的名称相同。为了避免丢失数据，我打算在删除旧的数据之前等几分钟。基于，
集群中的所有工作人员都使用相同的三个<em
浏览 8提问于2022-05-16得票数 0
回答已采纳
我有spring引导应用程序，它连接到我的kafka集群。应用程序(如kafka客户端)使用SASL身份验证，在初始化kafka生产者和使用者之前，我通过System.setProperty()指定了JAAS配置。它很好地工作在单卡夫卡集群设置。kafka_client_jaas.conf org.apache.kafka.common.security.plain.PlainLoginModule required&q
浏览 3提问于2020-07-22得票数 2
回答已采纳
我想列出所有以分布式模式在一个组中运行的Kafka连接工作人员。我的用例是，如果某个工人因任何原因关闭/死亡，我可以重新创建该工人以再次加入到该组中。而且，所有的工人都将在一个网络上的不同机器上运行。
浏览 1提问于2022-03-01得票数 0
:这是使用网络mode=host的多节点集群的汇合点示例.我应该使用什么地址进行内部连接。例如，下面的一个是单节点kafka集群。9092 KAFKA_BROKER_ID: 1 KAFKA_ADVERTISED_LISTENERS<e
浏览 0提问于2019-04-28得票数 0
回答已采纳
我无法连接到其他kafka集群节点的zk。要调试该问题，已尝试使用telnet连接到端口2181上的其他zk群集ip，但观察到它无法连接/到达。然而，如果我尝试telnet到端口2181的相同机器ip，它的工作正常&是连接的。即如何调试此问题并检查根本原因？另外，请确认confluent zk是否在内部使用telnet连接到zk集群？
浏览 5提问于2020-07-02得票数 0
1回答
我正在尝试从GKE集群内建立到驻留在GKE集群外部的数据库的连接。以下是我尝试设置kafka连接的示例配置： ---apiVersion: v1 name: kafka - addresses，但是如果我创建了一个pod，比如通过kubectl run -it --rm --restart=Never alpine --image=alpine sh，那么我就无法使用nc kafka 909
浏览 12提问于2020-01-19得票数 0
回答已采纳
现在我所理解的是，它们都必须连接到同一个zookeeper。好的，如果他们因为网络问题而不能呢？当网络再次可用时，复制是否会继续？
浏览 36提问于2018-03-05得票数 1
回答已采纳
我安装了kafka_2.11-1.1.0，并将广告侦听器设置为advertised.listeners=PLAINTEXT://<my-ip>:9092 (在$KAFKA_HOME/config/server.properties我可以使用java代码连接和写入我的kafka，并通过kafka-tool从另一台服务器看到我的集群，但是我不能从我的本地机器(我在其上安装了kafka集群的机器)向我的主题
浏览 0提问于2018-12-17得票数 6
回答已采纳
2回答
当我尝试同时向2个Kafka节点发送数据日志时，Filebeat出现问题output.kafka: hostsxxx.xx:9092", "192.168.zzz.zz:9092" ] timeout: 30s两个kafka我的意思是只有Kafka节点192.16
浏览 2提问于2018-11-17得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
