腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(718)
视频
沙龙
1
回答
如何
使用
Kafka
、
Alpakka
Kafka
、
Play
Framework
和
Websocket
处理
POST
请求
?
scala
、
websocket
、
apache-kafka
、
playframework
、
alpakka
假设我有两个
kafka
主题,request_topic用于我的帖子
请求
,response_topic用于我的响应。def socket =
WebSocket
.accept[String, String] { req => val requestId = ???基本上,对于每个传入的消息,我向
Kafka
发布一个
请求
对象,然后由某个流
处理
应用程序(此处未显示)
处理
该
请求
,并希望将响应发布回
Kafka
。我在这里有一些担忧: 1-
浏览 30
提问于2020-04-16
得票数 1
回答已采纳
2
回答
Kafka
接收器的HTTP
请求
源?
apache-kafka
、
playframework
、
akka-stream
如何
将
play
POST
路由接入
Kafka
Sink?
如何
使
POST
请求
路由成为绑定到
Kafka
接收器的源?编辑:
POST
请求
正文的格式为json,Content-Type为application/json。发送给
kafka
的消息应该是完全相同的json。该路由需要一条json消息。
浏览 0
提问于2020-06-17
得票数 0
1
回答
Apache
Kafka
与HTTP API
apache-kafka
我刚接触Apache
Kafka
和它的与API相关的流服务,但想知道是否有任何正式的文档来获取摄取所需的初始原始数据?从本质上讲,我想尝试构建一个初级的密码交易机器人,但我的印象是http API可能比与
Kafka
Streams集成的API具有更多的延迟。例如,我知道RapidAPI有一个可以访问的http库,可以帮助提取数据,但我不确定如果我想通过
Kafka
Streams摄取数据,是否有类似的东西。我试着在Google上挖掘,但不是很清楚
Kafka
Streams采用了什么API或源数据,或者它们是否相同/
浏览 0
提问于2021-06-05
得票数 0
2
回答
使用
java的播放框架中的
Kafka
使用
者
java
、
apache-kafka
、
playframework
、
kafka-consumer-api
我在java语言的
play
框架中搜索了数千个网站,寻找
kafka
消费者示例。但找不到任何例子。谁能提供详细的信息,
如何
编写一个服务,它消耗了卡夫卡不断产生的主题。 谢谢
浏览 3
提问于2020-02-03
得票数 0
1
回答
如何
在PlayFramework中通过Websockets将
Kafka
streams中的数据发送到客户端?
scala
、
playframework
、
websocket
、
apache-kafka
、
kafka-consumer-api
我
使用
的是Playframework
和
Scala。我正在尝试从
Kafka
消费数据,
处理
数据,然后通过websockets将数据推送到客户端。不幸的是,我仍然是这项技术的新手。import
play
.api.libs.json.JsValueimport
play
.api.libs.streams._ } // do i include my
浏览 4
提问于2016-05-19
得票数 3
1
回答
在
kafka
中
处理
大型Xml文件
scala
、
apache-kafka
、
kafka-producer-api
、
alpakka
我正在
使用
Alpakka
kafka
和
scala应用程序。我的
Kafka
在docker内部运行,我正在尝试
使用
我的代码在
Kafka
producer上发布消息。case Failure(e) => }代码没问题,但当我发送大的xml文件时,它会给出an error that org.apache.
kafka
.common.errors.RecordTooLargeExceptio
浏览 4
提问于2020-07-17
得票数 1
3
回答
如何
在WPF
和
ASP.NET应用程序之间进行通信?
c#
、
asp.net
、
wpf
我有一个WPF应用程序,我希望用户能够部署到web服务器,以便他们可以通过他们的web浏览器查看来自它的更新。我的WPF应用程序可以将对象实时发送到ASP.NET应用程序吗?如果是这样的话,是怎么做的?我应该关注哪种技术?
浏览 0
提问于2017-10-23
得票数 2
1
回答
Apache
kafka
..produce,并由同一应用程序
使用
spring
、
apache-kafka
、
kafka-producer-api
、
spring-kafka
、
camunda
我需要有一个Apache
kafka
生产者-消费者rest微服务应用程序,其中一旦我触发生产者rest端点,我应该立即获得确认消息
和
触发该服务的工作流,然后等待下一步(等待事件),该步骤将由消费者应用程序触发我
如何
实现这一点? 谢谢
和
问候,阿尔宾
浏览 42
提问于2018-05-31
得票数 0
1
回答
在apache中,在得到
kafka
的响应之前,生产者有什么配置来控制最大等待时间?
apache-kafka
在我们的应用程序中,对于每个导致数据更新/插入到DB的
请求
( REST端点后调用),我们必须向
Kafka
发布/生成一条消息,以便下游系统
使用
并进行进一步
处理
。而且,应用程序中大多数
POST
请求
的SLA为5秒,并且我们的大部分
POST
调用都是同步的。这意味着,在
POST
调用中结束的任何
处理
都应该在5秒内完成,以避免超时问题。
使用
这种设置,如果一个场景中我已经结束了一个DB调用,并在一个
POS
浏览 2
提问于2020-01-30
得票数 0
回答已采纳
1
回答
如何
编写用于生产的
Kafka
RestProxy服务器/客户端
scala
、
rest
、
apache-kafka
需要开发一个rest API,可以从
kafka
集群读取发布的消息到数据仓库应用程序。 网上提供的材料说
使用
POST
/GET命令,但我不认为这是用于生产用途,而是对测试目的很有用。
如何
在scala/ Java编程中实现它?
浏览 0
提问于2019-02-12
得票数 0
1
回答
基于微服务的应用程序
如何
能够同时
使用
服务网格
和
事件驱动体系结构?
architecture
、
microservices
、
mesh
、
event-driven-design
我遇到了一些应用程序,他们说他们
使用
事件驱动架构在微服务(
Kafka
作为事件代理)和服务网格(LinkerD)之间进行通信。如果应用程序
使用
kafka
作为事件代理在微服务之间进行通信,那么服务网格是
如何
出现在图片中的呢? 假设我们有ServiceA
和
ServiceB (都有多个部署/节点)。如果ServiceA想
和
ServiceB对话,它可以制作出一个卡夫卡主题,ServiceB可以订阅。服务网格
如何
存在于这种通信中,它
如何
浏览 3
提问于2022-03-07
得票数 0
回答已采纳
2
回答
基于Http
请求
的Spring
Kafka
监听器
java
、
spring
、
apache-kafka
、
spring-kafka
我
使用
Spring
和
Kafka
,我做了一个HTTP
POST
请求
,如下所示,并通过
Kafka
主题发送一些信息给另一个服务。@RequestMapping(method = RequestMethod.
POST
, value = "/portfolio") Authenticationuser.toDTO(); dto.setId(((AuthenticatedUser
浏览 29
提问于2019-01-03
得票数 1
回答已采纳
1
回答
nginx客户端关闭连接
docker
、
nginx
、
timeout
作为代理后端服务器(express.js)a数据库(Mongodb)前端服务器(express Js)用于日志记录的访问<code>H 210<//code><code>f 211<//code> 问题是当我
使用
POST
请求
到达后端端点时,响应永远不会发送给客户端。在firefox中
处理
1分钟,用铬
处理
5分钟后,会出现错误。据我所知,这些时间与这些浏览器的超时设置相匹配。我可以在firefox中增加超时,但这不是一个可
浏览 4
提问于2021-07-09
得票数 1
回答已采纳
1
回答
在微服务中同时
使用
api网关
和
消息代理
microservices
现在,我正在
使用
一个api网关来
处理
对我个人服务的所有get
请求
,并
使用
kafka
来
处理
异步
post
、put
和
delete
请求
。这是
处理
微服务架构中
处理
请求
的好方法吗?
浏览 0
提问于2017-04-26
得票数 1
回答已采纳
1
回答
如何
使
Kafka
接收器连接器在接收器启动时将数据从主题插入到表中
apache-kafka
、
apache-kafka-connect
、
confluent-platform
我已经为我的数据存储(Amppol )开发了
kafka
-sink-connector (
使用
confluent-oss-3.2.0-2.11,connect
framework
),它将
kafka
主题中的数据存储到我的存储中的相应表中只要
kafka
服务器
和
ADS服务器启动并运行,一切都像预期的那样工作。 需要关于特定用例的帮助/建议,其中事件在
kafka
主题中被摄取,而其下的接收器组件(ADS)已关闭。这里的期望是,每当接收器服务器出现时,先前在
kafk
浏览 1
提问于2017-04-04
得票数 0
1
回答
Apache Camel -
Kafka
组件-单生产者多消费者
java
、
apache-kafka
、
apache-camel
、
kafka-consumer-api
、
kafka-producer-api
我正在创建两个apache camel (blueprint XML)
kafka
项目,一个是
kafka
-producer,它接受
请求
并将其存储在
kafka
服务器中,另一个是
kafka
-consumer,它从
kafka
服务器获取消息并
处理
它们。这种设置对于单一主题
和
单一
使用
者来说工作得很好。但是,
如何
在同一个
kafka
topic中创建独立的消费群?
如何
在不同消费者组内的同一主题内
浏览 28
提问于2020-05-03
得票数 1
1
回答
使用
REST服务
和
Kafka
将CPU密集型工作分流给后台工作人员
rest
、
asynchronous
、
apache-kafka
、
message-queue
我正在开发一个接受用户
请求
的REST服务。每个用户
请求
都代表着繁重的计算工作。我不希望计算工作阻塞REST服务。我的设计是将用户
请求
包装为任务(具有唯一的任务id)并推送到
Kafka
。后台工作人员订阅
Kafka
并
处理
任何传入的任务。REST服务将任务保存到数据库中,将任务id推送到
Kafka
,然后立即返回任务id。用户
使用
任务id轮询任务状态。 这个设计很好。但我仍然不知道
如何
处理
一种情况:如果在将任务保存到数据库之
浏览 2
提问于2018-02-08
得票数 0
2
回答
卡夫卡用户-项目设计建议
apache-kafka
、
apache-flink
、
apache-kafka-streams
、
hazelcast-jet
对于我们的情况,假设我们有项目A、B
和
C。打开项目A的用户只看到/接收项目A的消息。消息到达时应该被推送到
Kafka
主题,让我们把这个主题称为根主题。消息一旦被推入根主题,可以由
Kafka
消费者/侦听器读取,并且基于消息中的项目标识符可以将该消息推送到特定于项目的主题。因此,任何消息都可能出现在主题A、B或C上。当websockets到达项目用户的仪表板时,考虑
使用
websockets更新消息。N个项目主题将有N个
使用
者/侦听
浏览 1
提问于2018-01-30
得票数 1
1
回答
node.js- no-
Kafka
-
Kafka
broker - MessageSizeTooLarge错误
node.js
、
apache-kafka
我们
使用
的是无
kafka
客户端的node.js。我们有一个文件上传功能,其中文件是json,然后它被读取并转换为Base64,生产者将其发送到
Kafka
。
Kafka
的消息大小限制配置为6MB 现在,当我上传一个4.3-4.4Mb大小的文件时,它会到达
Kafka
并被
处理
。在client.js文件中,我在生成
请求
的方法中打印了
请求
长度
和
消息集长度。当我打印4.5MB文件的消息长度时,它显示
请求
长度为6432489,大于6
浏览 4
提问于2017-10-25
得票数 0
1
回答
将数据帧从Spark写入
Kafka
(org.apache.
kafka
.common.errors.RecordTooLargeException)时出错
apache-spark
、
apache-kafka
我正在
使用
下面的参数将一个包含30000个条目的Dataframe写入
kafka
.option("
kafka
.bootstrap.servers",
kafka
_brokers) .option("
kafka
.max.request.si
浏览 0
提问于2021-01-30
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
使用 Kafka和MongoDB 进行 Go 异步处理
基于Kafka技术栈构建和部署实时搜索引擎的实践
10分钟带你玩转Kafka基于Controller的领导选举!
使用Kafka Streams构建事件溯源系统的经验分享
Spring 5的反应式WebSocket实战
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券