我使用kafkajs来公开从kafka主题读取的数据，这些数据将通过prometheus的http端点公开，以便抓取数据。但是我不能暴露来自kafka主题的数据。我已经写了这样一个生产者和消费者 Producer.js // import the `Kafka` instance from the kafkajs library
const
浏览 40提问于2021-03-31得票数 0
回答已采纳
我想知道我们是否可以从Kafka中公开一些REST API，这些API可以用于健康检查或类似的东西？
如果没有找到任何提供相关信息的博客。
浏览 3提问于2018-12-13得票数 1
卡夫卡中的demo.incoming话题堆积如山。
我正在使用。每秒大约有70个请求通过Scrapy Cluster REST api (Producer)提交给Kafka。蜘蛛可以非常快地完成爬行，因为redis中的队列保持在一个非常低的数字，大多数时间少于10个。但demo.incoming中的消息数量每秒都在堆积。这是我用来查看Kafka中demo.incoming主题消息数的</em
浏览 1提问于2019-07-07得票数 1
2回答
我正在尝试使用lagom框架编写一个小型微服务，并通过read实现以支持mysql。然而，在执行时，该项目没有创建kafka主题并向其发布消息。我尝试过调试、阅读文档和引用其他几个类似的项目，但到目前为止没有任何进展。
Lagom文档和类似的项目是唯一可以为这些相当新的技术找到任何帮助的来源。我真的需要帮助来调试和理解这个问题。让我知道，如果这是一个正确的平台，请
浏览 0提问于2019-08-24得票数 0
回答已采纳
我需要创建一个解决方案，从运行在kiosks上的web/桌面应用程序接收事件。全国各地都有数以百计的信息亭，每一个都会在事情发生时不时地自动生成事件和事件。我在研究可扩展但可靠的解决方案，发现Apache似乎是一个很好的解决方案。我知道有客户为NodeJS，但找不到任何选择角。由于这个原因，它必须通过HTTP/S与后端通信。最后，我意识到从角发送事件的最佳方法是创建一个API，该API只从HTTP/S端点
浏览 2提问于2021-10-06得票数 0
回答已采纳
2回答
我正在使用带有strimzi操作符的Kafka，我创建了一个Kafka集群，并使用yml文件部署了Kafka连接。但在这之后，我完全不知道下一步该做什么。我了解到Kafka connect用于将数据从源复制到Kafka集群，或者从Kafka集群复制到另一个目标。我想使用Kafka connect将文件中的数据复制到Kafka集群的any主题。谁能帮助我，我怎么做，
浏览 4提问于2020-11-20得票数 2
1回答
我想从RSS资源中开始阅读我的Kafka集群，所以我创建了一个"org.kaliy.kafka.connect.rss.RssSourceConnector“的连接器实例，它从特定的RSS提要读取，给出一个url，并写入特定的主题。我的意思是，如果一个连接器(在一个RSS提要:一个连接器实例中)停止工作，谁应该尝试再次启动它呢？通过Kafka连接REST
浏览 5提问于2020-12-04得票数 0
我想从每个Docker收集应用程序特定的度量。有各种应用程序，每个应用程序运行在一个或多个码头工人中。我想收集JSON格式的度量，以便对每种度量类型执行进一步的处理。我不喜欢这个选项，因为它意味着我需要知道存在哪些豆荚并访问每一个，而拥有Kubernetes的全部意义是避免处理这个问题。我正在寻找Kubernetes API HTTP请求，该请求将允许我提取特定的文件。我发现的最接近的是GET /api&#
浏览 0提问于2018-01-16得票数 0
3回答
消费者和流的区别是什么？对我来说，如果有任何工具/应用程序使用来自Kafka的消息，那么在Kafka世界中，它就是一个消费者。
我做了谷歌这个，但没有得到任何好的答案。
浏览 2提问于2017-05-17得票数 158
回答已采纳
希望有人知道这点或者能为我指明正确的方向..。我还有另一个规则主题，它提供通过向接收值添加新字段来增强数据主题记录的信息。
这两个主
浏览 0提问于2018-08-07得票数 1
回答已采纳
4回答
例如:用户进行REST (POST)调用来存储，比如产品。通常，我会在后端接收这个调用，并将主体保存到数据库中(经过验证和所有..)。最好的做法是先将这个调用存储在Kafka第一次中，然后将其保存到数据库中(在本例中，数据库是kafka消费者)。谢谢
浏览 2提问于2018-10-25得票数 4
回答已采纳
我有一个由docker-compose设置的应用程序。该应用程序包含用于kafka、postgres、rest api端点的docker容器。我很好奇是否有类似测试用例的测试框架。如何验证callback URL是否被数据命中？
浏览 0提问于2018-04-10得票数 1
2回答
选择调度机制
、、
作为依赖于来自互联网的不同数据馈送的web应用程序的一部分，我需要创建一个组件，通过网络从不同的地方提取数据，并使它们可用于我的web应用程序。它有一个要获取的资源列表，每个资源都有不同的计时。例如，需要每隔1小时拉取一个RSS feed，每隔30分钟调用某个REST API。
我已经实现了抓取部分。我现在想知道如何实现调度部分。我知道我可以使用windows计划任务或window
浏览 2提问于2012-04-16得票数 0
我想设置从kafka主题到cassandra的kafka连接{"id":"1", "name":"Alex", "clicks我正在研究，但我能找到的唯一示例是从cassandra读取，并通过中间的kafka写入另一个cassandr
浏览 1提问于2016-07-21得票数 2
3回答
我正在开发一个移动应用程序，我想从一个不是我使用Cordova的网站上提取一个文本值，我搜索了一下，但是我找不到一个有效的例子。有插件可以这样做吗？
浏览 11提问于2017-05-15得票数 1
回答已采纳
component: flask-app type: ClusterIP loadBalancer: {}
3.引擎盖下发生了什么？5.我在哪里可以找到更多关于这个概念的信息/文章？
提前谢谢你。感谢您在这里提供的任何建议和建议。
浏览 6提问于2021-10-29得票数 0
回答已采纳
4回答
我希望将工作实例发布到主题中，并运行一组相同的消费者来处理它们。当每个消费者完成其工作时，它将从主题中提取下一项工作。每个工作只应由一个使用者处理一次。我发现了一种模式，其中为每个消费者创建了一个唯一的分区。这“划分了工作”，但是在创建主题时会设置分区数。此外，必须在命令行上创建主题。bin/kafka-topics.sh --zookeeper localhost:2181 --partitions 3 --topic d
浏览 0提问于2018-07-17得票数 4
回答已采纳
我正在评估vert.x框架，看看是否可以减少使用spring引导开发的微服务之间基于Kafka的通信。问题是:我能代替
基于vert.x的spring引导微服务
浏览 1提问于2018-12-19得票数 13
回答已采纳
6回答
我正在学习微服务，我不明白创建REST API和创建microservices之间的真正区别是什么
我在Go工作，但我的问题适用于所有语言。
浏览 4提问于2017-08-12得票数 19
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号