腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
使用
kafka-node
创建
的
消费者
和
生产者
无法
连
接到
kafka
的
工作
实例
javascript
、
node.js
、
apache-kafka
我尝试通过
kafka-node
npm库
使用
consumer
和
producer,以便通过nodejs
使用
kafka
作为消息服务。问题是,尽管我
的
生产者
有时会
工作
,但
消费者
总是给我超时错误,或者它只是在无休止
的
循环中尝试连
接到
kafka
,即使tought也
工作
得很好。即使我把所有的代码(
消费者
和
生产者
)
和
浏览 56
提问于2019-06-19
得票数 3
3
回答
Node.js:如何
使用
kafka-node
从主题开始拉取消息?
node.js
、
apache-kafka
我跟随在Ubuntu14.04服务器上安装了
Kafka
。为
生产者
和
消费者
提供
的
示例运行良好。下面是
生产者
命令:下面是
消费者<
浏览 2
提问于2016-06-08
得票数 2
回答已采纳
2
回答
如何在NodeJS
Kafka
消费者
中直接获取上一个偏移量或过滤偏移量
node.js
我在
Kafka
NodeJS中
使用
了一个简单
的
消费者
/
生产者
。我
的
生产者
正在发送消息,我很容易在
消费者
中获得这些消息。
生产者
和
消费者
的
代码如下。在
消费者
中,我期望offset.fetch()给我今天
的
所有偏移量it,但它没有。KIndly指导我如何从这个方法中获得结果,并且还提到了一个方法,它可以直接给出任何分区主题中
的</em
浏览 1
提问于2015-07-29
得票数 3
1
回答
kafka
客户端正在发送请求到代理被关闭
的
分区。
node.js
、
apache-kafka
、
kafka-producer-api
、
node-kafka
我正在
使用
kafka
节点模块向
kafka
发送消息。在集群环境中,我有一个主题,其中有3个分区,复制因子为3。当我遵循下面的步骤
kafka
:9093send 获取连
接到
kafka
:9092
的
HighLevelProducer
实例
,a message 停止
kafka
-server:9092手动,然后用HighLevelProducer我期望
的
是,如果一个分区
无法
访问(代理已经关闭),
生产者</
浏览 3
提问于2019-09-23
得票数 1
2
回答
需要在EC2上运行
的
kafka
的
公共IP地址
amazon-ec2
、
apache-kafka
我们在一个亚马逊网络服务EC2
实例
上安装了
kafka
和
zookeeper。我们有
kafka
生产者
和
消费者
运行在不同
的
ec2
实例
上,它们在同一个私有网络上,与
kafka
实例
具有相同
的
安全组。在
生产者
或
消费者
配置中,我们
使用
kafka
服务器
的
内部IP地址来连接它。但是我们注意到,为了让
生产
浏览 3
提问于2018-10-31
得票数 0
1
回答
如何在EC2上设置Apache
Kafka
Broker?
amazon-web-services
、
amazon-ec2
、
apache-kafka
我已经在我
的
EC2
实例
上安装了Apache
Kafka
,更改了安全组,为
Kafka
和
Zookeeper打开了端口9092
和
2181。我只有一个单一
的
代理,单一
的
主题,单一
的
分区并不复杂。我通过尝试当地
的
生产者
/
消费者
确认了
Kafka
的
工作
。在AWS安全组上,它显示: 自定义TCP规则TCP 2181 0.0.0.0
浏览 3
提问于2016-12-12
得票数 2
1
回答
kafka
-节点:发送enum键消息(而不是字符串键)
node.js
、
apache-kafka
我正在
使用
从我
的
node.js web服务器生成消息。我
的
消费者
是另一个后端系统(用c++
和
编写)。var
kafka
= require('
kafka-node
'),
浏览 4
提问于2016-05-02
得票数 0
回答已采纳
1
回答
Kafka
Node High Level Producer仅写入偶数分区
javascript
、
apache-kafka
、
node-kafka
我正在
使用
Kafka
Node库,并测试高级生成器。 我
创建
了一个有10个分区
的
主题'HLPTestInput',并编写了一个每秒生成该主题
的
函数。
生产者
写入分区0、2、4、6
和
8,但不写入奇数分区。 奇怪
的
是,当我
使用
这个主题并生成第二个主题'HLPTestInputFromConsumer‘时,消息被写入所有分区。 我是不是遗漏了什么配置?const
kafka
= require(
浏览 34
提问于2019-02-17
得票数 2
2
回答
如何
使用
Kafka
节点从
kafka
主题中删除消息
node.js
、
apache-kafka
、
kafka-node
我
创建
了一个
生产者
和
一个
消费者
,
使用
“
Kafka
节点”包发送
和
消费来自
kafka
主题
的
信息。
生产者
和
消费者
通过API调用。POST方法用于向主题发送消息,而GET方法用于在
使用
者处从主题获取消息。当我在向
KAFKA
发送消息之后调用消费API时,所有以前
的
消息都在consumer.on('message', f
浏览 6
提问于2021-12-15
得票数 0
2
回答
如何
使用
NodeJs消费
Kafka
的
最新消息?
node.js
、
apache-kafka
、
kafka-consumer-api
、
kafka-node
我
创建
了一个NodeJS应用程序将数据插入到MongoDB集合中。此数据库插入是通过
使用
Kafka
完成
的
。卡夫卡-节点是我曾经称之为卡夫卡
的
插件。 每次我调用这个API时,
生产者
都会
创建
一个新消息并将其发送给
消费者
。在每个调用中,所有以前
的
消息都将返回给
使用
者。我<em
浏览 28
提问于2022-01-03
得票数 0
2
回答
在boot2docker中运行卡夫卡时
使用
JMX的卡夫卡监控
docker
、
boot2docker
、
apache-kafka
我试图让JMX监控来监控一个测试
kafka
实例
。 我有卡夫卡(千斤顶/卡夫卡)运行在码头通过boot2docker,但我不能得到正确配置
的
JMX监控。我已经做了大量
的
故障排除,我知道
kafka
实例
正在正常运行(
消费者
和
生产者
都在
工作
)。当我尝试简单
的
JMX工具(j控制台
和
jvisualvm)而两者都
无法
连接(不安全
的
连接错误,连接失败)
浏览 1
提问于2015-07-01
得票数 2
回答已采纳
1
回答
MSK、IAM
和
Kafka
Java Api
scala
、
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
、
aws-msk
因此,由于某些原因,我
无法
通过
Kafka
Java API正确连接MSK。我可以让
生产者
/
消费者
使用
conduktor
和
Kafka
CLI工具来
使用
MSK。但是,当我尝试挂接Scala代码时,我
无法
让它
工作
。因此,我
使用
如下配置通过conduktor
和
Kafka
CLI工具进行连接。应用程序,我
使用
类似的模式设置
生产者
浏览 124
提问于2021-08-31
得票数 0
回答已采纳
2
回答
连接被拒绝本地主机:9999 java.io.IOException:
无法
检索RMIServer存根: javax.naming.ServiceUnavailableException
java
、
apache-kafka
、
datadog
我正在
使用
Datadog从运行在我
的
本地主机上
的
Kafka
收集指标。当我在我
的
Datadog代理上运行-info命令时,这是我为
Kafka
得到
的
错误。你知道这是什么原因吗?
kafka
- instance #
kafka
-localhost-9999 [ERROR]: 'Cannot connect to instance localhost
浏览 33
提问于2016-08-27
得票数 0
1
回答
Apache
Kafka
节点js
和
点对点
工作
流
node.js
、
apache-kafka
、
kafka-consumer-api
因此,我刚刚开始探索
kafka
(
使用
节点js),并且
使用
kafka
节点模块与
kafka
交互。我刚刚编写了一些测试
消费者
代码(见下文
浏览 0
提问于2017-06-10
得票数 0
回答已采纳
1
回答
kafka-node
on ready事件未触发
javascript
、
node.js
、
apache-kafka
我已经为
Kafka
客户端
和
生产者
创建
了单例类,以便只
创建
一个对象。我需要多次发布相同
的
主题,而不需要
创建
新
的
客户端
和
生产者
实例
。我发现producer.on('ready',fn(){})没有
使用
相同
的
客户端
和
生产者
实例
触发,只有在我有新
的
客户端
和
浏览 3
提问于2017-06-01
得票数 0
1
回答
Kafka
服务器属性-
无法
连
接到
broker
amazon-ec2
、
apache-kafka
假设
Kafka
在AWS EC2
实例
上作为单个节点代理运行。
实例
拥有内部内网IP 10.0.0.1。我想从同一个EC2
实例
直接连
接到
该broker,也可以从同一个私有网络
和
子网中
的
另一个EC2
实例
连
接到
该broker。安全组允许连接。我必须
使用
哪些设置才能使连接运行?我试过listeners=PLAINTEXT://0.0.0.0:9092
和
advertised.listeners
浏览 0
提问于2017-05-29
得票数 0
1
回答
Kafka
HDFS接收器连接器重启
apache-kafka-connect
当我重新启动HDFS Sink Connector时,我是否会从上次读取
的
偏移量收到消息?连接器如何知道必须从哪里重新启动?
浏览 2
提问于2020-05-12
得票数 0
2
回答
kafka
nodejs -
使用
SASL身份验证
创建
生产者
和
消费者
的
问题
node.js
、
apache-kafka
我正在尝试
使用
nodejs
创建
带有SASL身份验证
的
Kafka
生产者
和
消费者
,但似乎在我尝试过
的
几乎所有nodejs
kafka
包中都没有提供(node-rdkafka,
kafka-node
,no-
kafka
使用
node-rdkafka尝试了下面的选项,但在
使用
sasl发布msgs时没有成功 var
Kafka
= require('n
浏览 1
提问于2017-12-19
得票数 2
1
回答
将信息从
kafka
消费者
推送到mongodb
node.js
、
mongodb
、
apache-kafka
、
kafka-consumer-api
、
apache-kafka-connect
我在活动上用“
kafka
-node”
创建
了
kafka
消费者
。consumer.on('message' ()=>{}) module.exports = { connectDB, getDB, clos
浏览 0
提问于2019-04-03
得票数 0
回答已采纳
1
回答
卡夫卡-
消费者
/
生产者
与所有Zookeper
实例
一起
工作
apache-kafka
、
apache-zookeeper
我
使用
kafka
_2.11-1.1.0发行版存档配置了一个
Kafka
代理集群
和
一个Zk
实例
集群。对于
Kafka
代理,我已经配置了config/server.propertieszookeeper.connect=box1:2181,box2:2181,box3:2181:2888:3888 我
创建
了一个基本
的
生产者
和
一个基本
的
消费者
,我不
浏览 0
提问于2018-09-25
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
SpringBoot整合Kafka中间件,上篇
Kafka之文件消费者应用案例
SpringBoot整合Kafka中间件,下篇
Kafka分布式流式处理平台
大数据流处理:Flume、Kafka和NiFi对比
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券