腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
Node.js
中的卡夫卡消费者
、
、
目前我正在用
Node.js
实现
Kafka
队列。我可以在Express中创建简单的API,并将数据推送到
Kafka
(生产者)中。我目前正忙于从
Kafka
获取数据,我正在使用
node.js
的
Kafka
-node库。所以任何人请帮帮我。
浏览 8
提问于2017-10-24
得票数 3
1
回答
kafka
-节点:发送enum键消息(而不是字符串键)
、
我正在使用从我的
node.js
web服务器生成消息。我的消费者是另一个后端系统(用c++和编写)。var
kafka
= require('
kafka
-node'), KeyedMessage=
kafka
.KeyedMessage,
浏览 4
提问于2016-05-02
得票数 0
回答已采纳
1
回答
卡夫卡消费者架构设计: java插件还是外部客户端
、
、
、
、
我正在为
kafka
集群(使用dockers for
kafka
)为数据使用者编写解决方案,但我仍然需要决定如何对其进行编码: 真正的表演消费卡夫卡的信息,而不制造瓶颈。整个web接口、rest服务以及数据持久化都是用
Node.js
开发的,客户端采用javascript /
浏览 1
提问于2018-12-20
得票数 0
回答已采纳
1
回答
布卢米克斯卡夫卡流
、
、
、
、
IBM的最新版本是否支持
Kafka
(在这里描述:)。有关于如何做到这一点的例子/示例吗?如果是的话,可以用
node.js
来完成吗?我想做的是 一个应用程序-前端(
Node.JS
浏览 4
提问于2016-09-14
得票数 3
1
回答
kafka
使用者应用程序的kafkajs代码中的意外标记
Nodejs版本: 4.4.7 NPM版本: 2.15.8 我正在运行以下代码,它是从以下URL复制而来的 https://
kafka
.js.org/docs/getting-startedconst {
Kafka
} = require('kafkajs') clientId: 'my-app', brokers: ['
kafka
1:9
浏览 21
提问于2019-10-04
得票数 0
1
回答
Kafka
在传统的3层应用程序中的位置
我最近开始学习apache
kafka
。在得到一些初步的想法后,我对
kafka
在应用程序架构中的位置感到困惑。 我的意思是,我们如何将它引入到以前只有三层的简单应用程序中。前端(安卓应用),后端(
Node.js
),MySQL。用户可以从应用程序创建帖子,应用程序将调用
node.js
上的端点,并将帖子存储在数据库中。在这个简单,直截了当的架构中,
kafka
还会添加什么额外的东西?它将如何集成?
浏览 2
提问于2021-10-27
得票数 0
1
回答
如何将
node.js
连接到kerberos
kafka
集群
、
、
、
、
我想使用
node.js
连接Kerberos
Kafka
集群。我研究了一些提供
Kafka
连接的NPM包,但没有发现任何特定的连接到Kerberos
Kafka
集群的东西。
浏览 11
提问于2017-03-09
得票数 1
1
回答
bitnami/
kafka
和confluentinc/cp的区别是什么?
、
我想用
Node.js
和
Kafka
创建一个dockerize项目一些例子在docker文件中使用和。Note:我还需要一个UI来管理Apache,所以基于,它使用confluentinc/cp-
kafka
,我不能将它与bitnami/
kafka
一起使用。bitnami/
kafka
和confluentinc/cp-
kafka
有什么区别,哪个更好呢?
浏览 5
提问于2022-08-17
得票数 1
回答已采纳
1
回答
IoT流数据处理的最佳实践
、
、
、
、
设备的数量仍在增加,因此我必须相应地扩展代理集群和数据处理模块,因为
Kafka
/Rabbit MQ/Hive MQ等MQTT代理可以非常容易地扩展,但对于数据处理模块,我不太确定是否有任何最佳实践或任何框架
浏览 4
提问于2016-12-17
得票数 3
1
回答
node.js- no-
Kafka
-
Kafka
broker - MessageSizeTooLarge错误
、
我们使用的是无
kafka
客户端的
node.js
。我们有一个文件上传功能,其中文件是json,然后它被读取并转换为Base64,生产者将其发送到
Kafka
。
Kafka
的消息大小限制配置为6MB有没有需要在
Node.js
或无
kafka
producer/client
浏览 4
提问于2017-10-25
得票数 0
1
回答
npm库
kafka
节点与
kafka
流的区别
、
在一个项目中,
Node.js
应用程序连接到
Kafka
消息队列并从队列中获取所有消息。我搜索并发现了两个包
kafka
-node和哪个包裹在这里合适?
浏览 3
提问于2020-06-15
得票数 1
1
回答
我是否可以使用角9中的
kafka
使用者/生产者来连接节点服务器?
、
、
、
我试图连接卡夫卡从客户端使用角-9与
node.js
服务器。这段代码运行在节点上,我想在angular9上做同样的事情“ const
kafka
= require('
kafka
-node'); const Consumer =
kafka
.HighLevelConsumer; const client = new
kafka
.Client(con
浏览 2
提问于2020-09-18
得票数 1
回答已采纳
0
回答
Kafka
-node仅适用于Zookeeper端口(2181)
、
、
当我尝试创建一个新的KafkaClient时,我必须指定我的节点的IP和
Node.js
上的端口2181。我通过
Kafka
在我的数据库中做了大量的插入操作,每次我让它运行一夜之后,我就会得到CONNECTION_LOSS[-4]错误,这一定与Zookeeper有关。在其他语言上,
Kafka
port9092用于生产/消费,但不适用于
Node.js
。 如何修复此问题并避免这些连接错误,并使用端口9092而不是2181?
浏览 3
提问于2018-07-14
得票数 0
2
回答
Apache
kafka
与Angular.js的集成
、
我在apache
kafka
中创建了一个主题'sample‘,并运行producer,将消息发布到其中。我在其他终端上运行了consumer,可以看到发布的消息。
浏览 0
提问于2014-11-24
得票数 0
1
回答
kafka
- consumer -groups CLI未显示节点-
kafka
使用者组
、
、
我有一个运行在
node.js
上的
kafka
消费者组,由node-
kafka
提供支持。当此消费者组处于活动或非活动状态时,我希望看到kafa- consumer -groups CLI报告它。
kafka
- consumer -groups CLI确实显示了控制台使用者,而不仅仅是节点使用者。
kafka
-consumer-groups --bootstrap-server local
浏览 21
提问于2019-11-11
得票数 2
3
回答
Node.js
:如何使用
kafka
-node从主题开始拉取消息?
、
我跟随在Ubuntu14.04服务器上安装了
Kafka
。为生产者和消费者提供的示例运行良好。下面是生产者命令:下面是消费者的命令: ~/
kafka
/bin/
kafka
浏览 2
提问于2016-06-08
得票数 2
回答已采纳
1
回答
如何将post web钩子从BitBucket配置到
Kafka
REST代理?
、
、
、
、
因此,我已经设置了
Kafka
rest代理,但是我不能将数据从BitBucket发送到
Kafka
,因为使用 is application/vnd.
kafka
.json.v2+json发布数据所需的Content-Type我已经在存储库级别配置了Web钩子,这是这样的: 这是从BitBucket的Web钩子中触发的请求:我从
Kafka
的REST代理中得到的反应是:我考虑了以下解决方案:我可以编写,一个简单的web服务器,充当两个系统(BitBucket和
Kafka
)之
浏览 0
提问于2019-05-26
得票数 1
1
回答
在码头动物园管理员和
kafka
的SASL认证
、
、
、
、
:
kafka
KAFKA
_ADVERTISED_LISTENERS: SASL_PLAINTEXT://
kafka
:9095
KAFKA
_OPTS: "-Djava.security.auth.login.config=/
浏览 2
提问于2020-05-20
得票数 4
2
回答
无法安装npm软件包(
kafka
-streams)
、
、
、
、
我正在尝试使用npm包,但下面是错误:gyp ERR! find VSgyp info ok似乎卡
浏览 1
提问于2019-07-27
得票数 0
回答已采纳
1
回答
在Bluemix和Node-Red中使用
Kafka
节点
、
、
、
我正在尝试使用
Kafka
输入节点( node-red -contrib-
kafka
- node )在Bluemix node-red应用程序中使用消息。
Kafka
输入节点的ZK Quorum属性中应该包含什么内容才能使用这些消息?
浏览 2
提问于2016-04-12
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Kafka权威指南(一):初识Kafka
Kafka权威指南(三):Kafka起源故事
聊聊 Kafka: Kafka 为啥这么快?
Kafka监控系统Kafka Eagle剖析
聊聊kafka结构,kafka基础了解
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
云直播
活动推荐
运营活动
广告
关闭
领券