腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
Node.
js
中的卡夫卡消费者
javascript
、
node.js
、
apache-kafka
目前我正在用Node.
js
实现
Kafka
队列。我可以在Express中创建简单的API,并将数据
推送
到
Kafka
(生产者)中。我目前正忙于从
Kafka
获取数据,我正在使用node.
js
的
Kafka
-node库。所以任何人请帮帮我。
浏览 8
提问于2017-10-24
得票数 3
2
回答
什么是
Kafka
等价物RabbitMQ的交换?
rabbitmq
、
apache-kafka
我有RabbitMQ背景,使用RabbitMQ,您可以设置交换,根据路由关键字将消息路由
到
不同的队列。 在
Kafka
中,我目前对主题的理解是,它们可以被认为是队列(永远不会被清空)。是否有与RabbitMQ的交易所等价的
Kafka
?
浏览 0
提问于2015-09-30
得票数 2
2
回答
如何从
kafka
消息总线
推送
通知消费者
c#
、
apache-kafka
、
confluent-platform
我正在使用C# asp.net Core2.0,
Kafka
,CQRS和Confluent
Kafka
.net库编写微服务应用程序。只是想知道
kafka
是否可以通知消费者,而不是消费者投票/消费消息? 谢谢
浏览 0
提问于2018-09-11
得票数 0
1
回答
Kafka
Confluent HTTP Sink连接器的开源替代方案
apache-kafka
、
kafka-consumer-api
、
apache-kafka-connect
我想从
Kafka
主题
推送
数据
到
REST端点。(非企业版,不使用confluent
kafka
托管服务)。我正在考虑使用Confluent的
Kafka
Connect HTTP接收器,但我意识
到
它有30天的试用期,之后它需要许可证。是否有其他开源/免费选项可用作Apache
Kafka
和REST API之间的双向桥梁。
浏览 4
提问于2021-07-19
得票数 0
1
回答
将KTable数据放入外部数据库
java
、
apache-kafka
、
apache-kafka-streams
我有一个场景,我需要将数据放在KTable中,并将KTable中的数据存储
到
Oracle11g DB中。做这件事的可能方法是什么?
浏览 4
提问于2017-10-09
得票数 0
2
回答
使用HiveStorageHandler的
Kafka
生产者
hadoop
、
hive
、
apache-kafka
、
kafka-producer-api
现在,我正在尝试编写一个自定义的HiveStorageHandler实现,用于使用Hive Table查询和
推送
消息
到
Kafka
。我正在尝试为
Kafka
复制这一点。我在上面找到了一个项目 在这里,他们试图使用hive表上的查询从
Kafka
读取数据。我希望在
kafka
主题上使用insert on the table。
浏览 5
提问于2018-11-25
得票数 0
2
回答
实时事件处理
apache-kafka
、
iot
、
flume
我把flume和
kafka
搞混了。我不想将事件存储在某个地方,因为我已经用最新的值更新了数据库。我真的需要spark,(flume/
kafka
) + spark,来满足处理端吗? 我们可以在没有水槽的情况下使用flume进行任何类型的处理吗?
浏览 13
提问于2017-06-29
得票数 1
1
回答
将前端(Vue.
js
、React和角)与
Kafka
集成,作为事件驱动体系结构微服务的一部分
javascript
、
apache-kafka
、
architecture
、
frontend
我正在探索一种新的架构/模式(实时事件驱动),其中前端(可以是vue.
js
、棱角或反应)调用多个rest服务,这些服务集成
到
诸如
kafka
这样的分布式流平台中。 我很难把这些放在一起。理由如下。
浏览 4
提问于2020-02-15
得票数 0
1
回答
无法使用汇合平台将Avro数据
推送
到HDFS
apache-kafka
、
hdfs
、
avro
、
apache-kafka-connect
、
confluent-platform
我有一个系统将Avro数据推入
到
多个
Kafka
主题中。 在更改主题名称之后,我启动了
kafka
-connect-hdfs。这一步骤也是成功的。在此之后,我开始将数据
推送
给
Kafka
,但是消息并没有被
推送
到HDF
浏览 2
提问于2017-01-20
得票数 1
1
回答
我的生产者(SQL Server)打开了,
Kafka
关闭了。如何重新处理发往
kafka
的消息?
apache-kafka
、
apache-kafka-connect
我正在使用Debezium SQL Server Source connector通过CDC将数据
推送
到
Kafka
。SQL Server表中的数据是连续插入的。当
Kafka
宕机时,数据还会插入
到
该表中吗?如果是这样,当我的
Kafka
打开时,如何获得这些记录?
浏览 13
提问于2020-05-22
得票数 0
回答已采纳
2
回答
Logstash
Kafka
输出插件
apache-kafka
、
logstash
我希望使用Logstash
Kafka
输出插件来发布事件
到
Kafka
主题。请澄清 谢谢
浏览 0
提问于2021-02-03
得票数 0
1
回答
消费者如何在卡夫卡中消费信息?
apache-kafka
如果在整个网络的某个地方有一个
Kafka
服务器“在那里”,我会假设消费者可能有两种方式可以使用这些消息: 首先,通过“订阅”主题,并实际上告诉
Kafka
服务器它正在监听的位置,这样当产生新消息时,
Kafka
浏览 3
提问于2016-03-07
得票数 5
1
回答
如何使用snowflake
kafka
连接器向snowflake摄取增量数据?
snowflake-cloud-data-platform
我有一个从
kafka
摄取数据
到
Snowflake的要求。我想用snowflake
kafka
连接器来设计这个摄取。我的理解是,我的接收器需要是一个variant表,所以连接器会将
kafka
消息
推送
到variant列。一旦数据在variant列中,我将需要运行另一个进程来读取variant列,解析它并将数据存储
到
相应的目标表中。请让我知道这是否是摄取
kafka
数据的最佳方法 谢谢
浏览 33
提问于2020-07-29
得票数 0
回答已采纳
2
回答
将阿夫罗讯息
推送
到卡夫卡主题
node.js
、
apache-kafka
、
kafka-node
我试着用
kafka
-node-avroError: Topic name or id is needed to build Schema at Object.Pool.getByName (/work&
浏览 6
提问于2020-08-14
得票数 0
1
回答
PyFlink -如何使用PyFlink
推送
数据
到
mongodb和redis?
python
、
mongodb
、
redis
、
apache-flink
、
pyflink
最近,我使用PyFlink完成了一个功能,从
Kafka
读取流数据,并将其插入
到
另一个
Kafka
中。那么,如何使用PyFlink向mongodb和redis
推送
数据呢? 首先感谢您的帮助!
浏览 90
提问于2021-06-01
得票数 0
2
回答
不同线程使用
Kafka
Producer
apache-kafka
、
kafka-producer-api
我有
Kafka
生产者为我的基于java的web应用程序,以
推送
消息
到
kafka
。根据文档,我可以看到
kafka
producer是线程安全的。这是否意味着我可以拥有
Kafka
producer的单个实例,并由不同的线程( web请求)使用它,在我的情况下,每个线程都会打开和关闭producer。这会产生什么问题吗?
浏览 2
提问于2016-03-24
得票数 17
回答已采纳
3
回答
为什么
Kafka
是拉取的而不是
推送
的?
apache-kafka
为什么
Kafka
是拉取的而不是
推送
的?我同意
Kafka
提供了我所经历的高吞吐量,但我不认为
Kafka
的吞吐量会下降,如果它是基于
推送
的。关于基于
推送
的如何降低性能有什么想法吗?
浏览 5
提问于2016-09-20
得票数 55
回答已采纳
1
回答
使用
Kafka
流中的会话窗口对记录进行排序并插入
到
MySQL数据库中
apache-kafka
、
ksqldb
我有一个想要按顺序将记录插入
到
MySQL中的用例。我在我的记录中有一个时间戳字段,我将其用作ROWTIME,然后在其上尝试会话窗口,并将其插入
到
将
推送
到主题中然后
推送
到RDS中的输出流中。这两条记录在
Kafka
中是按顺序被摄取的-记录2,记录1。但在MYSQL中,我需要记录1,然后是记录2,因为记录1的时间戳较低。我在流中尝试了5分钟的窗口会话。这种情况在
Kafka
内部可能吗?我可以重新排序
Kafka
中的记录,然后使用INSERT into语句
推送
到流
浏览 20
提问于2020-05-07
得票数 0
回答已采纳
1
回答
我们如何将
kafka
主题转储
到
presto中
apache-kafka
、
presto
、
kafka-producer-api
、
connector
我需要将JSON文件
推送
到
Kafka
主题中,用presto连接主题,并将JSON数据组织
到
一个可查询的表中。我正在学习本教程https://prestodb.io/docs/current/connector/
kafka
-tutorial.html#step-2-load-data 我不能理解这个命令是如何工作的/
kafka
-tpch load --broker localhost:9092 --前缀tpch。--TPCH型微型机 假设
浏览 12
提问于2020-12-17
得票数 0
回答已采纳
2
回答
使用
Kafka
和ELK堆栈的集中式日志记录
elasticsearch
、
apache-kafka
、
logstash
、
kibana
现在,我的架构师设计了一个解决方案,获取日志文件并提供给
kafka
主题,然后从
kafka
提供给logstash并
推送
到elastic search,这样我们就可以在kibana中查看日志。现在我对
Kafka
和ELK stack是个新手。谁能给我指出如何完成这项任务的正确方向?我了解
到
可以配置Log4J和SLF4J将日志
推送
到
kafka
主题。1.现在如何从
kafka
消费并加载到logstash中?我是必须写一个
kafka
消费者,还是可以
浏览 5
提问于2019-07-18
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
基于Kafka的订阅推送
Kafka端到端审计
Oracle数据同步到Kafka
LogStash采集数据到kafka
推送系统从0到1(五):推送消息如何丢失的
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券