我在我的mac上的minikube k8集群的Pod上运行了一个landoop kafka镜像。我有两个不同的服务来公开用于模式注册的端口8081和用于代理的端口9092。我已经在我的NodePort服务中映射了端口8081 -> 30081和9092 -> 30092，以便我可以从集群外部访问它。但是，当我尝试运行控制台消费者或我的消费者应用程序时，Kafka从不消费消息。要验证broker</
浏览 86提问于2018-02-13得票数 3
我使用minikube (而不是节点ip)作为主机和服务NodePort端口。尽管在火花日志中，我看到NodePort服务解析端点，而代理被发现为寻址的豆荚和端口：如何改变这种行为？
浏览 0提问于2019-01-24得票数 1
回答已采纳
当我设置kafka代理时，它的URL默认使用 例如"http://kafka-broker-ingress.knative-eventing.svc.cluster.local/example/default“ 我只能从k8集群内的资源发送事件。是否可以使用面向公众的URL设置kafka代理，以便它可以接收来自集群外部的事件？如果可以的话。多么? 谢谢
浏览 49提问于2021-06-02得票数 1
回答已采纳
1回答
我对kafka，docker和kubernetes都是新手。我尝试在minikube中运行单节点或多节点kafka集群，并使用.net控制台应用程序向/从kafka broker产生/消费消息。使用它，我可以创建一个简单的POC，它可以向kafka经纪人发送消息/从kafka经纪人接收消息？我花了太多的时间来使用和融合的简单生产者/消费者代码来实现这一点，但我只能使用minikube</
浏览 0提问于2018-03-29得票数 2
我可以单独访问每个吊舱，但我不能使用集群IP和Minikube中公开的端口访问整个服务。我不知道它会是什么，因为我遵循的具体步骤，如在视频。也许有人能发现问题所在？谢谢！
浏览 2提问于2022-10-14得票数 0
2回答
我在minikube中运行solr以获取POC。我想知道如何访问minikube中的solr。据我所知，我不能使用我的主机IP访问solr，它只能使用minikube IP - 192.168.99.100:8983/solr访问。我的目标是在从远程机器访问solr服务器时访问solr服务器。有什么建议吗？
谢谢
浏览 6提问于2018-02-11得票数 1
我的设置就像，我有一个生产者服务，作为minikube集群的一部分，它试图将消息发布到运行在主机上的kafka实例。- ip: 10.0.2.2 - name: "broker"从端点中提到的minikube集群内部获取主机的ip地址是通过以下命令获得的Broker may not be available.Broker may not be availabl
浏览 1提问于2020-05-18得票数 3
回答已采纳
1回答
我使用和成功地将Kafka部署到本地码头的Kubernetes (gcp & minikube)。#!producer.send(KAFKA_TOPIC, m)
在舵机上，我使用了这个选项来启用外部使用：
helm install --name kafka --setexternal.enabled=true --namespace kafka in
浏览 2提问于2018-09-04得票数 2
metadata: namespace: default app: kafka-cluster type:9092kafkacat输出 1 brokers:
broker</em
浏览 16提问于2021-02-10得票数 1
2回答
我的minikube中有我的kafka和zookeeper的以下配置：kind: Service name: kafka-servicespec: app: kafka - protocol: TCP name: kafka-port-b kafka-service.<em
浏览 4提问于2020-05-18得票数 2
Kafka部署是按照博客配置的：KAFKA_ADVERTISED_HOST_NAME = kafa服务集群IP，对我来说是10.106.84.132。....:3:3root@edmitchell-virtual-machine:~# kafkacat -b 10.106.84.132然后，我可以订阅和发布，但只有在卡夫卡容器内，它不工作从外部
浏览 1提问于2018-04-29得票数 1
我对Kafka和kubernetes的世界非常陌生，并试图在它上面做一个项目。我的要求可能听起来很愚蠢，但它有点像这样： Kafka生产者和kafka消费者仅部署在本地Minikube集群中。Kafka代理是一个中央代理，不存在于minikube集群中。我搜索了谷歌，知道如何连接Minikube和Kafka集群。但是我不知道如何从生产者(部署在k
浏览 28提问于2021-09-10得票数 0
在由kafka(1 broker)提供的PoC cloudera集群中，我试图通过公共IP与外部生产者一起向集群发送消息。我的集群节点托管在Azure中，所有这些节点都可以从运行外部生产者的本地计算机访问。在这篇伟大的文章之后，我找出了我需要的kafka侦听器配置，因为这个代理公共IP只能从我的本地机器上访问，并且在集群内部，它们只能使用它们的内
浏览 1提问于2018-09-25得票数 0
1回答
Stage 0:> (0 + 8) / 9]org.apache.kafka.common.errors.TimeoutException守则是：os.environ['PYSPARK_SUBMIT_ARGS'] = '--packages
org.apache.spark:spark-sql-kafka-0-10streamingDataFrame
浏览 0提问于2018-05-07得票数 0
回答已采纳
我正在使用在minikube上运行kubernetes，我公开了一个外部端口，并成功地使用了来自集群外部的生产者和消费者NAMEAGE1h
K
浏览 0提问于2018-07-03得票数 11
2回答
我在图中显示了这种情况。
我想配置kubernetes吊舱，以便它们可以与外部坞容器"mysql“对话，但我不知道如何配置它，特别是关于要告诉它们连接到的IP地址。
浏览 1提问于2019-02-05得票数 0
我让卡夫卡部署并运行在库伯奈特斯集群中。我使用的图像来自码头枢纽-
我不使用任何外部负载
浏览 5提问于2017-01-26得票数 13
我尝试过很多东西，包括无头服务、没有选择器的服务、更新minikube \etc\host，但都没有效果。我的无头服务kind: Service name: es-local-kafkaspec:---kind: Endpoints name: es-local-kafka - addresses:9191
- name:
浏览 7提问于2022-02-03得票数 2
回答已采纳
2回答
我有一个运行DCOS的小集群。我能够按照指南成功安装kafka。正在运行给出 "address": [ "10.131.24.6:9655","10.131.14.192:9181" "zookeeper": "master.mesos:2181/dcos-service-kafka<
浏览 8提问于2016-09-19得票数 0
1回答
卡夫卡在GKE中通过入口暴露
、、、、
在我们的GKE集群中，我有一个使用Strimzi运算符创建的kafka集群。我需要让它暴露在入口上，以允许外部团队为开发目的与其进行交互。我试图在互联网上公开它，但我似乎无法在GKE中找到正确的配置。它需要做一个SSL-通过。这在GKE中支持吗？下面是我正在使用的集群配置。annotations:
浏览 7提问于2022-05-26得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
