腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
布卢米克斯卡夫卡
流
、
、
、
、
IBM的最新版本是否支持
Kafka
(在这里描述:)。有关于如何做到这一点的例子/示例吗?如果是的话,可以用
node.js
来完成吗?我想做的是 一个应用程序-前端(
Node.JS
,D3.JS)实时使用这些
流
并更新仪表板。
浏览 4
提问于2016-09-14
得票数 3
1
回答
Rest
流
、
、
、
我正在构建一个简单的
node.js
rest,它将从Apache
流
生成数据。API应该会产生JSON,但我有问题要解决。如何获得像[{},{},{}]这样的每条消息的JSON数组,有帮助吗?(或者有什么更好的方法,比如如何通过Power BI来公开
Kafka
流
,并使其能够使用
Kafka
流
?)express'); var output1 = ''; var http = require(
浏览 0
提问于2018-03-20
得票数 2
2
回答
Node.js
中的卡夫卡消费者
、
、
目前我正在用
Node.js
实现
Kafka
队列。我可以在Express中创建简单的API,并将数据推送到
Kafka
(生产者)中。我目前正忙于从
Kafka
获取数据,我正在使用
node.js
的
Kafka
-node库。所以任何人请帮帮我。
浏览 8
提问于2017-10-24
得票数 3
2
回答
Apache Beam over Apache
Kafka
流
处理
、
、
、
Apache Beam和Apache
Kafka
在
流
处理方面有什么不同?我也在努力掌握技术和编程上的差异。 请通过您的经验报告来帮助我理解。
浏览 1
提问于2018-06-15
得票数 10
1
回答
阿帕奇卡夫卡的术语
、
、
我阅读了和更多的文章,以了解什么是
Kafka
以及如何在我的应用程序中使用它。然而,我对此感到非常困惑。卡夫卡为可靠性提供了一个复制因素。用
Kafka
和NodeJS (为数据提供rest )构建一个发布子系统是个好主意吗?提前谢谢。
浏览 4
提问于2016-04-19
得票数 0
回答已采纳
1
回答
如何使用Vue中的
Kafka
节点修复错误?
、
、
任何人在vue.js中使用
kafka
节点时都会遇到此错误。/node_modules/
kafka
-node/lib/wrapper/BrokerReadable.js (app.js:85751:6)at __webpack_require
浏览 7
提问于2022-11-17
得票数 0
1
回答
Kafka
- java客户端比较
、
我想在我的java程序中使用
Kafka
。哪个
kafka
java客户端最适合使用哪一个?你能指出卡夫卡溪流,卡夫卡连接和卡夫卡泉之间的区别吗?
浏览 1
提问于2017-11-15
得票数 0
回答已采纳
1
回答
有没有办法在
Node.js
中使用ksqldb表(推送查询)?
、
、
、
、
我已经用主题'topic1'测试了
Kafka
集群(模式在schema中)。我根据这个主题创建了
流
:WITH (
KAFKA
_TOPIC='topic1', VALUE_FORMAT='AVRO', TIMESTAMP目标:我想用
node.js
编写使用者,将这些消息(使用websockets)发送到浏览器(客户端),并在客户端将其可视化(实时)。 已经尝试过:
kafka
-node
浏览 3
提问于2021-04-14
得票数 1
1
回答
清除检查点位置后Spark结构化
流
的旧
Kafka
偏移消费
、
、
、
我已经使用Apache和Apache结构化
流
构建了一个应用程序。我面临以下问题。 通过清除
流
的检查点位置,我们停止了
流
并重新启动
流
。跑了5到6个小时后,
流
正在随机消耗旧卡夫卡的信息。星火版本: 2.4.0,
Kafka
-客户端版本: 2.0.0,
Kafka
版本: 2.0.0,集群管理器: Kubernetes
浏览 0
提问于2019-01-17
得票数 1
回答已采纳
1
回答
kafka
-节点:发送enum键消息(而不是字符串键)
、
我正在使用从我的
node.js
web服务器生成消息。我的消费者是另一个后端系统(用c++和编写)。var
kafka
= require('
kafka
-node'), KeyedMessage=
kafka
.KeyedMessage,
浏览 4
提问于2016-05-02
得票数 0
回答已采纳
1
回答
Apache Samza和Apache
Kafka
流
之间的区别(侧重于并行性和通信)
、
在Samza和
Kafka
流
中,数据
流
处理是在处理步骤( Samza中称为“作业”,
Kafka
Streams中称为"processor“)的序列/图(Samza中称为”数据
流
图“,
Kafka
Streams输入(Kakfa主题X) ->(工作者A) ->(工作者B) -输出(
Kafka
主题Y) 正确地说,Samza和
Kafka
流
都使用主题分区概念来复制工作
流<
浏览 2
提问于2016-12-09
得票数 27
1
回答
spring和Binder在与
Kafka
的交互方面有什么区别?
、
、
、
、
我的理解是,创建是为了与
Kafka
客户端API交互,后来创建项目是为了“构建与共享消息传递系统相连接的高度可伸缩的事件驱动的微服务”,该项目包括两个绑定程序,其中一个是允许与
Kafka
交互的绑定器。spring-cloud-stream-binder-
kafka
-streams
浏览 3
提问于2021-11-10
得票数 0
回答已采纳
3
回答
火花
流
不包含KafkaUtils
、
、
我创建了一个项目,我想在其中消费卡夫卡
流
。因此,我需要使用火花
流
中的KafkaUtils。但是当我尝试使用KafkaUtils时,它们无法被解决。我添加了火花
流
_2.11-2.0.1.jar,并尝试导入org.apache.scamk.Streing.
kafka
。但它也无法解决。亲切的问候
浏览 5
提问于2016-10-12
得票数 2
回答已采纳
1
回答
在AKS上部署Spring-Cloud-数据
流
时,如何使用外部托管的
Kafka
集群指定?
、
、
、
但是,我的项目已经有了自己的
Kafka
实例,运行在我想要使用的融合云上,而不是“内部”实例。然后,我还尝试了SCDF ()的Kubectl部署,并看到我需要再次运行这两个消息传递组件中的一个。我想知道配置SCDF以使用我自己的
Kafka
实例的最佳方法--有人能说明一下吗?
浏览 3
提问于2020-07-14
得票数 0
回答已采纳
1
回答
reactive-
kafka
:为什么出版商“选择”消费者?
、
val actorSystem = ActorSystem("ReactiveKafka")val publisher: Publisher[StringConsumerRecord] =
kafka
.consume(ConsumerPropertieslowercaseStrings", value
浏览 7
提问于2016-08-28
得票数 0
回答已采纳
1
回答
卡夫卡消费者架构设计: java插件还是外部客户端
、
、
、
、
我正在为
kafka
集群(使用dockers for
kafka
)为数据使用者编写解决方案,但我仍然需要决定如何对其进行编码: 真正的表演消费卡夫卡的信息,而不制造瓶颈。整个web接口、rest服务以及数据持久化都是用
Node.js
开发的,客户端采用javascript /
浏览 1
提问于2018-12-20
得票数 0
回答已采纳
1
回答
卡夫卡0.11中的KafkaUtils类
、
、
、
我们使用火花
流
从卡夫卡读和写,并使用KafkaUtils libary在火花
流
_2.11,其中有卡夫卡0.10.0 libs。是的,我正在将
kafka
客户端jars升级到0.11来使用一些功能,但是由于星火
流
有
kafka
0.10,所以它没有被使用,我试着把它排除在火花
流
之外,但是它抱怨KafkaUtils类以下,只在0.10甚至2.3也与
kafka
0.10 (spark-streaming-
kafka
-0-10_2.11-2.3.0.cloudera
浏览 0
提问于2020-03-24
得票数 1
1
回答
在python中聚合
Kafka
记录
、
我想要聚合来自
kafka
的记录
流
。我知道在JAVA中有
kafka
流
的实现,但我不熟悉JAVA,我想知道在python中有没有执行这样的任务的选择,与
kafka
流
相比,它有多好?
浏览 22
提问于2020-03-19
得票数 0
1
回答
如何让
kafka
在spring运行时使用http
流
数据?
、
、
、
在spring运行时,可以让
kafka
源模块作为处理器模块工作吗?有代码样本吗?我正试图实现这样的目标: http (xd源)、xd源(xd处理器)、xd使用者(xd接收器)stream create kafkaSourceTest --definition "http --outputType=application/json |
kafka
--zkconnect=localhost:2181 --topic=k
浏览 3
提问于2015-05-12
得票数 0
回答已采纳
1
回答
坞式组合中的
Kafka
流
需要很长时间进行分区分配。
、
、
、
我正在码头容器中运行一个
Kafka
流
应用程序。出于测试目的,我有一个用于运行
流
应用程序、
kafka
的单个实例和动物园管理员的坞-撰写文件。卡夫卡和动物园管理员的配置以前都是有效的。为
kafka
流
应用程序分配分区需要5分钟以上。如果我延迟运行
流
容器,直到
kafka
和zookeeper启动,并且
流
应用程序正在使用的主题已被正确实例化,那么它几乎立即得到其分配的分区。看起来
kafka
流
组正在被实例化,但是
浏览 0
提问于2018-01-05
得票数 5
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
创建 Node.js 视频流应用之后端
使用Spark Streaming处理Kafka数据流
带你了解大数据消息流系统Kafka
storm+kafka+redis的实时订单流
通过Pipelinedb使用SQL查询Kafka实时流数据
热门
标签
更多标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
活动推荐
运营活动
广告
关闭
领券