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实现Kafka队列。我可以在Express中创建简单的API，并将数据推送到Kafka(生产者)中。我目前正忙于从Kafka获取数据，我正在使用node.js的Kafka-node库。所以任何人请帮帮我。
浏览 8提问于2017-10-24得票数 3
Apache Beam和Apache Kafka在流处理方面有什么不同？我也在努力掌握技术和编程上的差异。
请通过您的经验报告来帮助我理解。
浏览 1提问于2018-06-15得票数 10
1回答
我阅读了和更多的文章，以了解什么是Kafka以及如何在我的应用程序中使用它。然而，我对此感到非常困惑。卡夫卡为可靠性提供了一个复制因素。用Kafka和NodeJS (为数据提供rest )构建一个发布子系统是个好主意吗？提前谢谢。
浏览 4提问于2016-04-19得票数 0
回答已采纳
任何人在vue.js中使用kafka节点时都会遇到此错误。/node_modules/kafka-node/lib/wrapper/BrokerReadable.js (app.js:85751:6)at __webpack_require
浏览 7提问于2022-11-17得票数 0
我想在我的java程序中使用Kafka。哪个kafka java客户端最适合使用哪一个？你能指出卡夫卡溪流，卡夫卡连接和卡夫卡泉之间的区别吗？
浏览 1提问于2017-11-15得票数 0
回答已采纳
我已经用主题'topic1'测试了Kafka集群(模式在schema中)。我根据这个主题创建了流：WITH (KAFKA_TOPIC='topic1', VALUE_FORMAT='AVRO', TIMESTAMP目标：我想用node.js编写使用者，将这些消息(使用websockets)发送到浏览器(客户端)，并在客户端将其可视化(实时)。
已经尝试过： kafka-node
浏览 3提问于2021-04-14得票数 1
我已经使用Apache和Apache结构化流构建了一个应用程序。我面临以下问题。
通过清除流的检查点位置，我们停止了流并重新启动流。跑了5到6个小时后，流正在随机消耗旧卡夫卡的信息。星火版本: 2.4.0，Kafka -客户端版本: 2.0.0，Kafka版本: 2.0.0，集群管理器: Kubernetes
浏览 0提问于2019-01-17得票数 1
回答已采纳
我正在使用从我的node.js web服务器生成消息。我的消费者是另一个后端系统(用c++和编写)。var kafka = require('kafka-node'), KeyedMessage= kafka.KeyedMessage,
浏览 4提问于2016-05-02得票数 0
回答已采纳
在Samza和Kafka流中，数据流处理是在处理步骤( Samza中称为“作业”，Kafka Streams中称为"processor“)的序列/图(Samza中称为”数据流图“，Kafka Streams输入(Kakfa主题X) ->(工作者A) ->(工作者B) -输出(Kafka主题Y)
正确地说，Samza和Kafka流都使用主题分区概念来复制工作流<
浏览 2提问于2016-12-09得票数 27
我的理解是，创建是为了与Kafka客户端API交互，后来创建项目是为了“构建与共享消息传递系统相连接的高度可伸缩的事件驱动的微服务”，该项目包括两个绑定程序，其中一个是允许与Kafka交互的绑定器。spring-cloud-stream-binder-kafka-streams&#x
浏览 3提问于2021-11-10得票数 0
回答已采纳
3回答
我创建了一个项目，我想在其中消费卡夫卡流。因此，我需要使用火花流中的KafkaUtils。但是当我尝试使用KafkaUtils时，它们无法被解决。我添加了火花流_2.11-2.0.1.jar，并尝试导入org.apache.scamk.Streing.kafka。但它也无法解决。亲切的问候
浏览 5提问于2016-10-12得票数 2
回答已采纳
但是，我的项目已经有了自己的Kafka实例，运行在我想要使用的融合云上，而不是“内部”实例。然后，我还尝试了SCDF ()的Kubectl部署，并看到我需要再次运行这两个消息传递组件中的一个。我想知道配置SCDF以使用我自己的Kafka实例的最佳方法--有人能说明一下吗？
浏览 3提问于2020-07-14得票数 0
回答已采纳
val actorSystem = ActorSystem("ReactiveKafka")val publisher: Publisher[StringConsumerRecord] = kafka.consume(ConsumerPropertieslowercaseStrings", value
浏览 7提问于2016-08-28得票数 0
回答已采纳
1回答
我正在为kafka集群(使用dockers for kafka)为数据使用者编写解决方案，但我仍然需要决定如何对其进行编码：
真正的表演消费卡夫卡的信息，而不制造瓶颈。整个web接口、rest服务以及数据持久化都是用Node.js开发的，客户端采用javascript /
浏览 1提问于2018-12-20得票数 0
回答已采纳
1回答
我们使用火花流从卡夫卡读和写，并使用KafkaUtils libary在火花流_2.11，其中有卡夫卡0.10.0 libs。是的，我正在将kafka客户端jars升级到0.11来使用一些功能，但是由于星火流有kafka 0.10，所以它没有被使用，我试着把它排除在火花流之外，但是它抱怨KafkaUtils类以下，只在0.10甚至2.3也与kafka0.10 (spark-streaming-kafka-0-10_2.11-2.3.0.cloudera
浏览 0提问于2020-03-24得票数 1
我想要聚合来自kafka的记录流。我知道在JAVA中有kafka流的实现，但我不熟悉JAVA，我想知道在python中有没有执行这样的任务的选择，与kafka流相比，它有多好？
浏览 22提问于2020-03-19得票数 0
在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
回答已采纳
我正在码头容器中运行一个Kafka流应用程序。出于测试目的，我有一个用于运行流应用程序、kafka的单个实例和动物园管理员的坞-撰写文件。卡夫卡和动物园管理员的配置以前都是有效的。为kafka流应用程序分配分区需要5分钟以上。如果我延迟运行流容器，直到kafka和zookeeper启动，并且流应用程序正在使用的主题已被正确实例化，那么它几乎立即得到其分配的分区。看起来kafka流组正在被实例化，但是
浏览 0提问于2018-01-05得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
