腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Kafka
自动
提交
在
幕后
是
同步
还是
异步
?
java
、
apache-kafka
、
kafka-consumer-api
如果
kafka
enable.auto.commit=true,是否意味着每隔5秒它就会在
幕后
触发
同步
或
异步
操作以
提交
偏移? 小间隔(2秒)会以某种方式影响延迟吗?
浏览 21
提问于2019-01-24
得票数 1
回答已采纳
1
回答
卡夫卡消费者中的复制问题
python
、
apache-kafka
在
分区0上测试一条
Kafka
消息,处理时间超过一个小时。我尝试过
自动
提交
,暂停/恢复,增加最大轮询超时,但我无法停止消费者消息复制。这是使用python的融合式
kafka
。我看不出有什么方法可以实验
异步
/
同步
提交
。
浏览 3
提问于2022-03-07
得票数 0
1
回答
将数据发布到iframe
是
同步
还是
异步
?
javascript
、
iframe
、
submit
、
http-post
将数据发布到iframe
是
同步
还是
异步
?当我调用form.submit()时,
幕后
发生了什么?
是
同步
还是
异步
?
浏览 0
提问于2012-08-23
得票数 0
1
回答
gRPC和
Kafka
如何在微服务架构中协同工作
apache-kafka
、
microservices
我
是
微服务架构的新手。我很好奇,大多数人都在讨论如何选择grpc(
同步
)或
kafka
(
异步
)来进行微服务之间的通信,但没有人讨论如何使它们
在
同一个微服务系统中协同工作。对于我工作过的公司的系统,我知道每个微服务都使用grpc作为请求/响应,而
kafka
作为消息传递组件。他们
是
如何在
幕后
工作的?消息的有效负载是什么样子的?
浏览 64
提问于2021-10-17
得票数 0
1
回答
合流-
kafka
-dotnet-
提交
异步
.net
、
apache-kafka
、
confluent-platform
我
在
我的应用程序中使用了confluent-
kafka
-dotnet,并希望控制每条消息的
提交
,
在
我的示例中,处理消息做一些工作(
异步
)并
提交
消息,我
在
GitHub中查看了项目中的示例,并注意到
在
文档中注意到
提交
消息
同步
--与使用者能够使用消息的速度相比,这是非常慢的。因此,我
在
文档中搜索并注意到,在过去,这是
提交
消息的
异步
方法,但它只被更改为
同步</em
浏览 2
提问于2020-01-28
得票数 2
3
回答
表单
提交
是
同步
还是
异步
?
javascript
我只是想知道document.myForm.submit()是不是一个
同步
调用,它会一直阻塞到完成...或者如果它是
异步
的,并且将继续执行,而不等待
提交
返回。谢谢你的帮助。
浏览 2
提问于2011-11-03
得票数 12
回答已采纳
1
回答
Kafka
消费者偏移量
提交
在
可完成的未来
java
、
multithreading
、
java-8
、
apache-kafka
、
kafka-consumer-api
我在线程中创建了一个
Kafka
消费者实例,作为构造函数的一部分,在线程中的run方法中,我调用了不同的web服务,为了保持调用无阻塞,我使用了可完成的future。我的问题
是
我不能通过调用thenApply方法并传递
Kafka
消费者实例来发出
提交
,因为它给我一个错误,即
Kafka
消费者不是线程安全的。虽然
在
我的commit方法中,我已经编写了代码 commitResponse();我
还是
得到了Concurren
浏览 1
提问于2017-09-23
得票数 1
1
回答
卡夫卡消费者
在
重新启动时使用旧的信息
apache-kafka
、
confluent-platform
、
consumer
我正在使用来自某个主题的
Kafka
消息,但问题
是
,每当消费者重新启动时,它都会读取较旧的处理过的消息。我看到
Kafka
已经默认启用了
自动
提交
到true。
浏览 1
提问于2020-07-20
得票数 0
1
回答
在
Server 2014上将数据丢失强制转移到辅助副本时
sql-server-2014
、
availability-groups
、
failover
设置:2个副本
在
同步
提交
。
在
同步
提交
时为两个副本配置的
自动
故障转移。问题:使用以下命令执行手动强制故障转移: AVAILABILITY组AccountsAG FORCE_FAILOVER_ALLOW_DATA_LOSS; 这导致了大量的数据丢失。
浏览 0
提问于2019-05-16
得票数 1
1
回答
向JMSTemplate代理发送非持久性消息时的"sessionTransacted“行为
spring
、
activemq
、
spring-integration
、
jmstemplate
我希望了解spring JMSTemplate中事务会话的行为(
同步
或
异步
),同时向ActiveMQ代理发送非持久性消息。我指的是JMSTemplate配置,其中处理会话,发送的消息是非持久性。根据我的理解: 发送给ActiveMQ代理的非持久性消息被发送到
异步
。但是,
在
事务会话上发送的消息
是
同步
的。因为
提交
调用是
同步
的,所以每次发送消息后都会
提交
JMSTemplate。使用上述指定的配置发送消息
是
同步</e
浏览 3
提问于2014-07-17
得票数 1
2
回答
卡夫卡-曾经的生产者和消费者
apache-kafka
、
kafka-consumer-api
、
kafka-producer-api
我正在为一个简单的数据管道实现只需一次的语义,使用
Kafka
作为消息代理。通过设置set enable.idempotence=true,我可以强制
Kafka
producer对每条生产记录只写一次。然而,
在
消费方面,我需要保证消费者只读取每条记录一次(我对将消费的记录存储到外部系统或另一个正在处理的
Kafka
主题中不感兴趣)。在这种情况下,我是否需要求助于
Kafka
事务API来
在
消费者轮询循环中创建事务生产者,其中
在
事务中我执行:(1)处理所使用的记录和(2)
浏览 0
提问于2020-10-10
得票数 1
1
回答
为什么SQL AG
同步
提交
模式被归类为无数据丢失HA解决方案,即使会话超时可以使模式
异步
?
sql-server
、
availability-groups
、
clustering
、
sql-server-2019
假设SQL AG处于
同步
提交
模式。假设辅助服务器没有响应,或者二级服务器有网络问题,那么
在
会话超时到期时,AG将
自动
转换为
异步
模式。那么,为什么SQL AG
同步
提交
模式被归类为无数据丢失HA解决方案,即使会话超时可以使模式
异步
?
浏览 0
提问于2022-05-17
得票数 -4
1
回答
泉.卡夫卡.消费者.
自动
偏移复位在春季
是
如何工作的--卡夫卡
java
、
spring
、
apache-kafka
、
kafka-producer-api
、
spring-kafka
但预期的结果
是
,只对我发送的最新3个选项调用@KafkaListener方法。我试着使用另一种选择:但行为
是
一样的。 this.template.send("spring_
kafka
_topic", "foo2"); this.template.send("spri
浏览 5
提问于2017-10-16
得票数 4
1
回答
SQL服务器是否
在
异步
提交
模式AG中提供
自动
页面修复?
sql-server
、
availability-groups
、
sql-server-2019
我了解到,当主服务器与辅助服务器
同步
时,SQL AG支持
自动
修复页面。 假设AG
是
在
异步
提交
模式下配置的,那么是否也意味着主服务器和辅助服务器
是
同步
的(我知道会有延迟),提供
自动
页面修复吗?
浏览 0
提问于2022-05-16
得票数 1
2
回答
crm 2011 OP:插件运行在哪个服务器上?
dynamics-crm-2011
、
dynamics-crm
、
crm
、
dynamics-crm-2013
我们通常将
同步
、预验证、完全信任插件部署到数据库中.当插件运行时,有人能澄清哪些服务器资源会受到影响吗?如果我们同时执行了大量的插件,您会认为应用服务器或db服务器受到的影响最大吗?更新:我想我真正想问的
是
,如果我
在
一个附加插件的实体上触发消息(无论
是
UI
还是
应用程序),那么
幕后
会发生什么。具体来说,在上面的场景中,当插件运行时,插件运行在哪个服务器内存空间?
异步
/
同步
和消息处理阶段会影响它吗?例如,如果插件
是
同步<
浏览 0
提问于2015-12-05
得票数 2
3
回答
是否可以
同步
呈现dust.js模板?
javascript
、
asynchronous
、
sync
、
dust.js
我正在尝试为客户端HTML/JS模板系统编写一个适配器,以便在
幕后
使用dust.js。不幸的
是
,API期望呈现操作
同步
发生:呈现的输出应该从render()调用中返回。Dust.js
是
异步
的,并将呈现输出传递给回调函数。有没有办法解决这个问题,无论
是
在
Dust API中
还是
通过一些疯狂的Javascript黑客?
浏览 2
提问于2012-03-24
得票数 19
回答已采纳
1
回答
在
两个节点可用性组上增加tempdb数据文件
sql-server
、
sql-server-2012
、
availability-groups
、
tempdb
不幸的
是
,我们没有启动即时文件初始化,因此,PREEMPTIVE_OS_WRITEFILEGATHER将以等待最多30分钟(基于测试)的方式来限制tempdb数据文件的增长。我担心这些等待会影响应用程序/用户体验,下面
是
我的建议。禁用
同步
在
节点A上进行更改启用
同步
。
浏览 0
提问于2018-04-29
得票数 0
1
回答
为什么WCF的
自动
生成代理有
同步
方法?
.net
、
visual-studio
、
wcf
、
asynchronous
、
async-await
我实现了
异步
WCF服务MyServiceAsync。
在
客户机中,当我添加Service Reference时,它仍然生成此函数的
同步
(正常)版本。它甚至不返回任务,其名称是MyService。我以前有过
同步
版本,最近我更改为
异步
版本。这些剩饭
是
来自我以前的服务,
还是
VS
自动
生成
同步
和
异步
?谢谢
浏览 0
提问于2018-02-13
得票数 2
回答已采纳
1
回答
Spring:批处理模式+
异步
提交
。如何从卡夫卡经纪人的失败中恢复过来?
asynchronous
、
spring-kafka
集群节点崩溃,
kafka
开始报告异常,而不是接受我们的
提交
。默认
异步
回调只是将这些错误打印到日志中。投票仍在继续。消息处理得很好(但没有
提交
)。10分钟后,prod支持
在
日志中发现错误。卡夫卡集群恢复了,苦难进程被反弹。由于
提交
被代理删除了一段时间,该进程处理了大约200万条重复消息。我们可以
在
并发映射中保留每个TopicPartition的最新成功偏移量。因此,
在
代理再次破产的情况下,我们可以确保失败的偏移量高于最近的成功偏移量,然后.wh
浏览 3
提问于2021-03-07
得票数 0
1
回答
KafkaTemplate事务发送
同步
还是
异步
?
spring-kafka
我试图找出如何正确地处理,原子式多次将写到事务上下文中的
kafka
。在此场景中,事务不是由
kafka
消息侦听器启动的,而是以编程方式使用@ transaction注释启动的,请参见下面的代码段。我用的
是
spring 2.4.2和2.6.5。 KafkaProducer文档说,
在
事务上下文中,它不需要调用返回的未来的.get(),因为
在
尝试
提交
事务时,它最终会抛出异常。此外,KafkaTemplate对KafkaProducer返回的未来调用.get(),因此它看起来
是
<
浏览 3
提问于2021-02-04
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
在线等,Kafka如果丢了消息怎么办?
360开源又一力作——KafkaBridge:让操作kafka更简单!
微服务架构的稳定性与数据一致性能如何快速提高?
深入Kafka系列(二)consumer开发
4.kafka生产者&消费者
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券