使用CNCF的Strimzi Kafka Bridge，我创建了一个小API，它可以使用HTTP/1.1协议与Kafka服务器交互。这对于请求-响应场景来说是很好的。但是，我的要求是在收到Kafka主题上的事件时，立即将它们流式传输到订阅客户端(通过Strimzi桥)，最好是通过长时间的HTTP连接(根据我的理解)。我希望Kafka服务器将这些事件直接流到客户端。 我对SSE、Websoc
浏览 29提问于2019-10-05得票数 2
回答已采纳
对于社区来说，这是一个非常普遍的问题，特别是Kafka Strimzi Bridge的人，如果他们正在阅读这篇文章的话。我正在尝试将他们的Apache Kafka HTTP Bridge实现为某个POC。文档非常非常糟糕，并且没有提供任何帮助。我真的只需要知道你是如何使用桥发布和消费Kafka主题的消息的。
浏览 20提问于2019-10-02得票数 1
我按照下面的链接在k8s中创建了strimzi集群运算符 https://medium.com/@sincysebastian/setup-kafka-with-debezium-using-strimzi-in-kubernetes-efd494642585下载strimzi 0.17.0版本并解压缩。为了解决这个问题，我在集群运算符conf文件中添加了STRIMZI_KUBERNETES_VERSION。出口：- {}入口：- {} 有没有人能帮我解决一下这里缺
浏览 55提问于2020-04-12得票数 0
我有一个问题，那就是如何用Istio Ingress网关配置Strimzi操作符，以同时为引导和代理服务提供服务。我已经将Istio部署到以下网关和虚拟服务中，用于服务器引导和代理：kind: Gateway
metadata:客户端，以便通过Ingress使用，它还将在同一个端口上创建一个侦听器，因为Istio无法服务同一个端口。Stimzi Kafk
浏览 8提问于2022-04-05得票数 0
回答已采纳
我正在使用strimzi操作符并在k8上运行kafka集群。我想使用Kafka Mirror Maker，我使用CRD yml部署了Kafka Mirror Maker，但我的KMM的pod处于crashLoopBack状态。我不知道问题是什么？whitelist: ".*" 还有我的kafka-cluster yml： apiVersion: kafka.strimzi.io/v1be
浏览 48提问于2020-11-20得票数 0
由于我使用的是MirrorMaker v1，这些变量也被添加到KafkaMirrorMaker yaml文件中的KAFKA_MIRRORMAKER_MESSAGE_HANDLER和KAFKA_MIRRORMAKER_MESSAGE_HANDLER_ARGS但我不知道如何将这个自定义jar文件物理地添加到KafkaMirrorMaker荚中。我已经检查了KafkaMirrorMaker的CRD，但还没有找到任何线索。我目前正在使用的apiVersion of KafkaMirrorMaker：kaf
浏览 5提问于2021-11-25得票数 0
回答已采纳
我正在尝试添加用户名和密码到我在strimzi ..i上的kafka桥，不知道我是否配置正确，如果我配置正确，为什么我不能使用我的用户名和密码访问这里是我所做的步骤： secret.yaml apiVersionv1metadata:type: Opaque my-password: cmdoR0ZETColMTY3Cg== bridge.yamlapiVersion: kafka.strimzi.io&
浏览 825提问于2021-03-30得票数 0
3回答
如何进入卡夫卡桥
、、
我正在使用strimzi，我想学习如何使用Kafka桥，并了解它的工作原理，我使用以下yml文件创建了一个Kafka集群现在是服务
ist@ist-1207:~$ kubectl get
浏览 2提问于2020-11-23得票数 0
回答已采纳
我是一个新的kafka空间，我在Kubernetes中安装了Strimzi集群运算符、Kafka引导服务器、实体操作符和kafka connect，遵循以下准则：
apiVersion: kafka.strimzi.io/v1beta2
name
浏览 16提问于2022-09-22得票数 0
1回答
我想要访问我的卡夫卡集群使用nodeport.Here是我的CRD使用，我试图暴露卡夫卡使用nodeport。apiVersion: kafka.strimzi.io/v1beta1metadata:spec: version-0 -c kafka -it -n strimzi -- cat /tmp/st
浏览 2提问于2020-11-23得票数 0
回答已采纳
我正在使用Strimzi，Kafka，Kafka Connect和一个自定义连接器插件，遵循。
部署工作正常，Kafka Connect工作正常，我可以使用它的RESTFUL API。此外，我运行cat /tmp/strimzi-connect.properties并看到插件路径：plugin.path=/opt/kafka/plugins/。(该文件由strimzi在部署期
浏览 6提问于2021-12-10得票数 0
回答已采纳
我能够设置桥并连接到现有的Kafka集群，并使用HTTP请求读取数据。有没有办法添加一层安全性并公开一个HTTPS端点来获取Kafka记录，而不是普通的HTTP？
浏览 17提问于2019-11-14得票数 0
回答已采纳
我在Kubernetes中遇到的大多数使用Kubernetes的例子都是将它作为headless service部署，但是我还无法得到为什么它应该是无头而不是Cluster IP的答案呢？在我看来，IP提供了负载平衡，在这种负载平衡中，我们确保不仅一个broker总是装载其资源，就像我看到的无头Kafka客户机一样--无论是sarma还是java客户机都试图从DNS lookup中选择第一个或者Kafka已经处理了这个内置的，我仍然在试图理解它是如何发生的。
浏览 5提问于2020-01-17得票数 3
我有一个简单的python Kafka生产者，我试图访问GKE上的Strimzi集群，我得到了以下错误：要获取pem文件(从机密- PKCS文件)，以下是使用的命令{.data.ca\.password}' | base64 -d > ca.pa
浏览 6提问于2021-12-02得票数 0
回答已采纳
1回答
我有一个Strimzi集群，使用下面的yaml部署。在端口9094上启用了LoadBalancer，而没有TLS。# KafkaDeployment.yamlkind: Kafka name: dataproc-pocapiVersion: kafka.strimzi.io/v1beta2metadata:
na
浏览 7提问于2022-01-31得票数 0
回答已采纳
我有两组，我的挑战恰恰是如何从我的应用程序中连接到这个kafka。有大约10个微服务运行，每个必须连接到卡夫卡。
现在，我有了一种方法，将Strimzi作为Nodeport服务，并在应用程序代码中提供Ip和nodeIp。还有一个更关键的条件是，卡夫卡只能通过我们的应用程序访问，它不应该在公共互联网上使用。
浏览 0提问于2021-09-13得票数 0
回答已采纳
2回答
我们有一些应用程序希望使用REST API调用与Kafka通信，以消费和生成消息。如果我们不想使用Confluent REST代理，有什么选择呢？
浏览 10提问于2020-01-24得票数 2
1回答
我已经使用Strimzi在Kubernetes上配置了一个Kafka集群。使用本文- ，但我公司的安全服务不希望使用自签名证书在UAT中部署此解决方案。您能告诉我，我可以将我们的信任证书从一个可信的冲浪中心导入到这个Kafka解决方案中吗？is kafka.Error, not *kafka.Message
main.main.func2(0xc421004060)
&
浏览 3提问于2021-04-15得票数 0
我对fabric8io 的使用有一个问题。Caused by: com.fasterxml.jackson.databind.JsonMappingException: No resource type found for:kafka.strimzi.io/v1#Kafka
at [Source:
浏览 31提问于2021-03-18得票数 1
回答已采纳
4回答
我想在集群上部署kafka，但我不知道如何在配置中使用strimzi。我的动物园管理员吊舱正在2.4.FailedScheduling <unknown> default-scheduler pod has unbound immediate PersistentVolumeClaims
我通常用hostpath作为我的卷编辑：我试图使用Arghya的命令创建一个StorageClass，但问题仍然存在。strimzi</em
浏览 18提问于2020-01-07得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
