腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
使用
Spring
Data
和
Kafka
处理
跨
多个
线程
的
事务
java
、
apache-kafka
、
spring-data
、
spring-kafka
我正在开发一个应用程序,它
使用
Kafka
来
使用
来自
多个
主题
的
消息,同时持久化数据。 为此,我
使用
了一个@Service类,并用@kafkaListener注释了几个方法。与此相关
的
是,每个侦听器中
的
doHandle()方法在表中执行插入,偶尔会失败,因为一旦完成最终提交,自动生成
的
键就不是唯一
的
。发生
的
情况是,每个doHandle()方法都会在它们自己
的
小
事务
中增
浏览 17
提问于2021-01-20
得票数 0
回答已采纳
1
回答
使用
jpa
和
kafka
的
spring
交易示例?
spring-boot
、
kafka-producer-api
在将
spring
boot从2.1.11版本升级到2.2.5之后,
kafka
客户端将在jpa
事务
提交之前向代理生成消息。在没有
使用
链式
kafka
事务
管理器
的
情况下,
事务
运行良好。在2.1.x
和
2.2.x之间
的
事务
中是否引入了向后兼容性更改?有人能提供
跨
JPA
和
Kafka
的
事务
管理器吗?对于JPA,我只
使
浏览 2
提问于2020-03-17
得票数 1
2
回答
Kafka
多
线程
发布到同一分区
apache-kafka
、
spring-kafka
我有数千条记录要在一个
事务
中发布到同一分区上
的
Kafka
。我正在
使用
spring
KafkaTemplate来做这件事。为了提高我当前逻辑
的
性能,我正在考虑在多
线程
中进行
Kafka
发布。所有要发布
的
事件都具有相同
的
键,并且旨在转到相同
的
分区。
使用
多
线程
会导致
多个
线程
之间
的
偏移量冲突吗?我应该坚持
使用</
浏览 34
提问于2018-08-03
得票数 0
2
回答
我可以
使用
springboot来设计中间件应用程序吗?
spring
、
transactions
我计划重新设计我现有的用core java编写
的
中间线
事务
处理
系统。是弹簧启动将是一个很好
的
选择。现有的应用多采用纯TCP、Soap、Rest.RabbitMQ、FTP等多种传输通道进行通信。注意:系统正在进行分布式
事务
处理
。即完成一个简单
的
客户端请求,它与分布式
事务
一起工作
浏览 2
提问于2018-04-30
得票数 0
1
回答
Spring
+
Kafka
:交易缓慢
performance
、
apache-kafka
、
kafka-consumer-api
、
spring-kafka
刚开始
使用
Spring
(2.1.4.RELEASE)
和
Kafka
(1.0.0),但是当我添加
事务
时,
处理
速度大大降低。代码:
spring
.
kafka
.consumer.specific.avro.reader=true
spring
.
kafka
.consumer.auto-offset-res
浏览 0
提问于2018-04-10
得票数 2
回答已采纳
1
回答
使用
Spring
Boot
的
多
线程
事务
性
Kafka
生产者
和
消费者
multithreading
、
spring-boot
、
apache-kafka
、
spring-kafka
、
spring-transactions
我有一个项目,其中
使用
Spring
Boot相关项目。我想在项目中
使用
Kafka
的
消费者
和
生产者
的
事务
功能。我需要尽可能高效地在
Kafka
中产生大量
的
消息。所以我需要一个多
线程
的
消费
和
生产来满足这个需求。
如何
使用
Spring
boot开发多
线程
消费者
和
生产者?
浏览 81
提问于2020-10-14
得票数 0
回答已采纳
1
回答
InvalidPidMappingException导致
kafka
流应用程序关闭
apache-kafka
、
apache-kafka-streams
,协调程序
的
事务
id过期时,就会发生此异常。关于这一例外情况,我没有几个问题: 我认为在这个异常之后,生产者将重新尝试将它
的
事务
id与协调器同步,然后继续运行,而不会导致
kafka
流
线程
被杀死。即使我将上面的代码片段更改为不退出InvalidPidMappingException上
的
Spring
,它仍然会杀死流
线程
。是否有办法避免InvalidPidMappingException?上
的
流
线程
死
浏览 6
提问于2021-04-19
得票数 0
1
回答
与
Kafka
和
Postgres在春季
的
传奇
和
本地交易
spring-data-jpa
、
microservices
、
rdbms
、
spring-kafka
、
saga
已经有一段时间没有
使用
SAGA
和
spring
-
kafka
(
和
spring
-cloud-stream-
kafka
-binder)了。他们
使用
Database-per-Service方法(每种服务都将数据存储在Postgres中),并通过
Kafka
作为事件商店进行协作。我将应用SAGA (要么是编排方法,要么是编排方法,让我们坚持第一个)来管理
多个
服务上
的
事务
。问题是:当
使用
浏览 2
提问于2020-06-05
得票数 1
1
回答
数据访问层之外
的
事务
管理
java
、
hibernate
、
transactions
数据访问层不负责transaction management,我说
的
对吗?我有以下DAO实现:HibernateDAO and SqlDAO。如果我选择Hibernate并在上面的层
处理
它
的
事务
管理,那么当我切换到SQL时,我会改变Hibernate to SQL所做
的
每一个
事务
管理吗?这很糟糕,对吧?在这种情况下,我将
使用
什么策略?
浏览 4
提问于2014-07-24
得票数 0
2
回答
JMS会话对象在单个
线程
上下文中
使用
的
原因
java
、
multithreading
、
concurrency
、
jms
我是JMS
的
新手。因此,对于在座
的
专家来说,这可能是一个很难回答
的
问题。然而,我很难尝试找到一个非常重要
的
概念,即JMS是
如何
部署到工作中
的
。来自(粗体强调地雷) 会话对象是用于生成
和
使用
消息
的
单
线程
上下文。尽管它可以在Java虚拟机(JVM)之外分配提供者资源,但它被认为是一个轻量级JMS对象。我认为JMS
的
主要优点是消息
的
异步传递。异步这一术语自动引入了并发生成
和</
浏览 3
提问于2013-06-26
得票数 3
5
回答
数据库与
Kafka
生产者之间
的
事务
同步
apache-kafka
、
spring-transactions
、
spring-kafka
、
distributed-transactions
我们正在考虑
使用
(在
Spring
服务中),我可以看到它有一个,但据我所知,这更多是关于卡夫卡交易本身(确保卡夫卡生产者
和
消费者之间
的
一致性),而不是在两个系统之间同步交易(参见:“
Kafka
不支持XA,您必须
处理
DB可能在
Kafka
tx回滚时提交
的
可能性”)。此外,我认为这个类依赖于
Spring
的
事务
框架,至少就我目前所理解
的
来说,它是
线程
绑定
的</e
浏览 0
提问于2018-09-06
得票数 63
回答已采纳
1
回答
如何
在SpringBatch中维护DB连接
和
事务
java
、
spring
、
hibernate
、
spring-batch
、
spring-transactions
我希望用
spring
批
处理
和
调度器实现我
的
用例,以便在特定
的
时间点运行。我读过关于
spring
的
文章,并且了解到在块中有一个ItemReader、ItemProcessor
和
ItemWriter作为执行活动
的
作业。ItemReader中
使用
spring
事务
管理器在其他模块中实现
的
DAO从数据库读取记录。我是
Spring
批
处理
<e
浏览 1
提问于2016-07-18
得票数 1
1
回答
建议在Springboot中
使用
Hibernate吗?
spring-boot
、
hibernate
、
jta
我必须
使用
hibernate
和
弹簧引导。是否建议在此堆栈中
使用
JTA
事务
管理器? 如果建议
使用
JTA,
如何
在控制器或服务层中以编程方式访问当前会话?用例子会更有帮助。
浏览 2
提问于2020-07-29
得票数 1
回答已采纳
1
回答
Spring
Kafka
消费者ACKMODE &
Kafka
事务
的
生产者缓冲
spring-kafka
、
kafka-producer-api
我需要
使用
consume process-produce模式来
处理
Kafka
消息,并配置了一个带有
Kafka
事务
管理器
的
Spring
Kafka
侦听器容器,还设置了transaction-id-prefix我
使用
了批
处理
的
ack-mode,并试图了解在这种
事务
模式下,何时会实际提交偏移量。文档似乎表明,一旦
使用
了轮询中
的
所有记录,ack-mode
浏览 20
提问于2020-03-12
得票数 0
回答已采纳
2
回答
Spring
JPA多
线程
java
、
multithreading
、
spring
、
jpa
、
threadpoolexecutor
我们正在构建一个产品,所以从性能
的
角度来看,我需要一些帮助。我们
使用
的
是完整
的
Spring
(MVC、JPA、Security等)我将Futures/Callables用于多
线程
目的,但问题是它无法
浏览 1
提问于2012-11-10
得票数 1
回答已采纳
1
回答
多
线程
环境下
的
Spring
Hibernate SessionFactory.getCurrentSession
multithreading
、
spring
、
hibernate
、
sessionfactory
我写了一个批
处理
应用程序,它产生
多个
线程
来读取分配
的
文件并将记录保存到数据库中。该架构
使用
Spring
context
和
Hibernate。
事务
由
Spring
管理,我
使用
SessionFactory.getCurrentSession获取一个会话,为每个
线程
执行一个保存操作。考虑到我有一个
处理
get、save、update操作
的
泛型DAO
和
一个隐
浏览 1
提问于2015-01-08
得票数 1
1
回答
Camel JMS组件多
线程
java
、
spring-boot
、
apache-camel
、
spring-jms
、
solace
我有一个
spring
boot应用程序,
使用
Camel
的
jmsComponent
处理
来自
多个
Solace队列
的
消息。我为每个队列连接定义了一个Camel route,并定义了一个将消息转换为json
的
Camel Processor。有大量来自队列
的
消息,而我
的
程序无法跟上速度。brokers={{
spring
.
kafka
.bootstrap-servers}}&securityProtoco
浏览 22
提问于2020-07-21
得票数 1
1
回答
我们正在为
Kafka
使用
,我们正在寻找与
使用
者API完全相同
的
一次语义
kafka-consumer-api
、
kafka-producer-api
、
spring-cloud-stream
我们正在为
Kafka
使用
,并寻找精确
的
一次语义。我们有一个很好
的
解决方案,如预期
的
那样工作:( 1)
使用
MetaDataStore检查来自消费者端
的
重复消息(offsetId + partitionId + topicName),
使用
上面的解决方案,我们没有任何消息丢失和重复
处理
。但是现在我们发现有一个属性(producer.sendOffsetsToTransaction)
Kafka
帮助我们修复来自消费者端<em
浏览 0
提问于2019-03-27
得票数 0
回答已采纳
1
回答
春季云流卡夫卡在生产者一方
的
交易
spring-kafka
、
spring-cloud-stream
我们有一个
使用
卡夫卡
的
春季云流应用程序。需求是,在生产者端,消息列表需要放在
事务
中
的
主题中。在同一个应用程序中没有消息
的
使用
者。当我
使用
spring
.cloud.stream.
kafka
.binder.transaction.transaction-id前缀启动
事务
时,我面临
的
错误是,调度程序没有订阅服务器,而且从主题获得
的
分区总数少于配置
的
事务
浏览 7
提问于2019-09-29
得票数 0
回答已采纳
2
回答
如何
回滚
Spring
批
处理
中
的
所有步骤
java
、
spring
、
spring-batch
我创建了一个作业,它将我
的
文件分成几个小块,所有这些块都在分开
的
步骤中读取。为了前夫。3步完成,没有任何错误,记录被提交到数据库,但如果第4步失败,我需要回滚前一步
的
所有记录。
浏览 2
提问于2013-11-15
得票数 8
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
体系课Java亿级项目架构设计与落地应用【无密完结】
微服务架构的稳定性与数据一致性能如何快速提高?
“Spring和Kafka”Kafka整合Spring 深入挖掘-第1部分
Kafak的吞吐量为何这么高呢?
Spring for Apache Kafka 3.0和Spring for RabbitMQ 3.0发布
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券