腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(693)
视频
沙龙
1
回答
为什么
KafkaTransactionManager
没有
被
应用到
这个
Spring
Cloud
Stream
Kafka
生产者
?
、
、
、
我已经配置了一个
Spring
Cloud
Stream
Kafka
应用程序来使用事务(full source code available on Github):
spring
: name: message-relay-service
stream
: binder:
浏览 23
提问于2019-06-27
得票数 0
回答已采纳
1
回答
我们正在为
Kafka
使用,我们正在寻找与使用者API完全相同的一次语义
、
、
我们正在为
Kafka
使用,并寻找精确的一次语义。我们有一个很好的解决方案,如预期的那样工作:( 1)使用MetaDataStore检查来自消费者端的重复消息(offsetId + partitionId + topicName),使用上面的解决方案,我们
没有
任何消息丢失和重复处理但是现在我们发现有一个属性(producer.sendOffsetsToTransaction)
Kafka
帮助我们修复来自消费者端的重复处理,而
没有
任何元存储逻辑。现在我们还不确定如何使用
这个
属性.sendOffsetsToTr
浏览 0
提问于2019-03-27
得票数 0
回答已采纳
1
回答
春云流多主题事务管理
、
、
、
全局事务
被
回滚,但这并
没有
真正起到任何作用,因为第一条消息已经提交。
spring
:
stream
: binder:{ @Value("${
spring</e
浏览 0
提问于2019-08-06
得票数 2
回答已采纳
1
回答
在事务中包装StreamBridge发送和JPA保存
、
、
、
我试图包装一个rest服务调用,它使用JPA (CrudRepository.save)将记录保存到DB,然后使用StreamBridge使用
spring
云流(
kafka
binder)将消息发送到
Kafka
我试过几件事,但似乎
没有
什么效果很好。我故意造成JPA问题(插入违反唯一键约束的行),但是
Kafka
消息似乎仍然传递给代理。我已经配置了一个
KafkaTransactionManager
(
没有
使用ChainedKafkaTransactionManager,因为现
浏览 2
提问于2021-07-20
得票数 4
回答已采纳
1
回答
承认一条信息不应该让它被重新传递给卡夫卡消费者吗?
、
、
、
我正在运行
Stream
应用程序,在该应用程序中,我从
Kafka
主题读取事务,处理事务,然后将它们发送到IBM。当
没有
与IBM的连接时,我试图处理
这个
错误,以防止事务丢失。期望的行为是事务保持在
Kafka
主题中,而流侦听器再次读取它。然而,消息似乎只
被
消耗了一次,并且
没有
发生“回滚”。要做到这一点,以下是我的心声:
cloud
:
kafka
:
浏览 1
提问于2019-08-02
得票数 1
回答已采纳
1
回答
如何在属性文件弹簧引导中设置Acks=all
、
、
我想在我的春季云流卡夫卡应用程序中为我的
生产者
设置acks=all属性。我试过这样做:和和
spring
.
cloud
.
stream
.
kafka
.
浏览 1
提问于2019-04-24
得票数 1
1
回答
如何保护制作人的
kafka
主题?
、
、
、
我有多个
生产者
将消息推送到我的
kafka
代理中。我想保护我的主题,这样
生产者
需要密码才能在主题中推送消息或任何形式的保护。#
spring
.
cloud
.
stream
.
kafka
.binder.co
浏览 0
提问于2020-08-22
得票数 2
1
回答
春季云流卡夫卡在
生产者
一方的交易
、
需求是,在
生产者
端,消息列表需要放在事务中的主题中。在同一个应用程序中
没有
消息的使用者。当我使用
spring
.
cloud
.
stream
.
kafka
.binder.transaction.transaction-id前缀启动事务时,我面临的错误是,调度程序
没有
订阅服务器,而且从主题获得的分区总数少于配置的事务
浏览 7
提问于2019-09-29
得票数 0
回答已采纳
1
回答
属性文件中
kafka
生产者
的映射配置失败
、
、
我正在尝试将
生产者
配置添加到我的项目中,使用
Spring
Integration和下面的
Kafka
。但是,我无法使用以下任何格式编译代码:
spring
.
cloud
.
stream
.
kafka
.bindings.outpu
浏览 4
提问于2019-02-18
得票数 0
1
回答
春云流产生与消费的主题
、
我有一个使用
Spring
和的服务。
这个
服务产生一个特定的主题,同时也使用
这个
主题。(KafkaMessageChannelBinder.java:149) [
spring
-
cloud
-
stream
-binder-
kafka
-1.2.1.RELEASE.jar!(KafkaMessageChannelBinder.java:88) [
spring
-
cloud
-
stream
-binder-
kafka
-1
浏览 5
提问于2017-09-28
得票数 1
2
回答
Kafka
Binders for
Spring
Cloud
不使用事务性回滚
、
、
、
我正在尝试通过
Spring
Cloud
在一个事务中向
Kafka
中的两个单独的主题发送消息。当在第一条和第二条消息之间抛出异常时,第一条消息仍然出现在第一个主题的使用者中,表明消息
没有
回滚。tm = new
KafkaTransactionManager
<>(pf); }application.yml包含以下内容:
stream
: bindin
浏览 0
提问于2021-07-09
得票数 1
1
回答
弹簧云函数路由
、
、
、
、
=false
spring
.
cloud
.
stream
.
kafka
.bindings.articleAggregated.producer.configuration.client.id=articleAggregated
spring
.
cloud
.
stream
.
kaf
浏览 4
提问于2021-11-17
得票数 0
回答已采纳
1
回答
弹簧云卡夫卡绑定查询
、
、
突然,我们观察到
生产者
正在向主题发送重复的信息,然后我们使
生产者
是幂等的。为了更好的控制,我们让autocommitOffSet做错了。我还设置了以下事务属性
spring
.
cloud
.
stream
.
kafka
.binder.transaction.transactionIdPrefix=TX-
spring
.
cloud
.
stream
.
kafka
.binder.transaction.producer.configur
浏览 3
提问于2021-09-28
得票数 0
2
回答
春云中的动物园管理员数据流保持断开
、
、
:417) ~[
spring
-
cloud
-
stream
-binder-
kafka
-1.0.2.RELEASE.jar!:417) ~[
spring
-
cloud
-
stream
-binder-
kafka
-1.0.2.RELEASE.jar!=zookeeper:2181
spring
.
cloud
.dataflow.applicationProperties.
stream
.
spring
.
浏览 4
提问于2017-03-09
得票数 1
回答已采纳
1
回答
Spring
@Output KStream Serdes似乎无法工作
、
)配置如下
spring
.
cloud
.
stream
.
kafka
.streams.bindings.responseo.producer.key-serde=org.springframework.
kafka
.support.se
浏览 2
提问于2019-02-25
得票数 0
回答已采纳
2
回答
Kafka
在属性文件中创建了比硬编码更多的分区。
、
、
、
我已将我的
生产者
配置为:
spring
.
cloud
.
stream
.bindings.pc-abc-out
spring
.
cloud
.
stream
.bindings.pc-abc-out-0.producer.partition-count=10
spring
.<e
浏览 8
提问于2022-01-24
得票数 2
回答已采纳
1
回答
Spring
Cloud
Stream
-为个人消费者/
生产者
提供Serdes
、
、
、
、
我只想把它放在一个消费者身上
spring
.
cloud
.
stream
.
kafka
.binder.consumerProperties.value.deserializer=io.confluent.
kafka
.serializers.KafkaAvroDeserializer如果我这样做,它就会起作用
spring
.
cloud
.
stream
.bindings.scheduler-in-from-external-event.content-type=a
浏览 13
提问于2020-10-28
得票数 0
回答已采纳
1
回答
缺少KafkaBinderConfigurationProperties中的管理属性
、
但是,
没有
管理属性。我想知道在设计时,是否有具体的原因
没有
考虑到管理属性。以下是我认为上述两种选择的一些缺点, 对于使用
spring
.
cloud
.
stream
.
kafka
.configuration.xxx,如果我只想将一些属性配置为admin,那么我还必须设置另外两个属性
spring
.
cloud
.
stream
.
kafka
.consumer-
浏览 27
提问于2022-11-18
得票数 1
1
回答
spring
-
cloud
-
stream
kafka
消费者并发
使用
spring
-
cloud
-
stream
的
kafka
绑定器,如何配置并发消息消费者(在单个消费者jvm中)?如果我理解正确的话,使用
kafka
时使用并发消息消耗需要分区,但指出,要使用分区,您需要通过partitionKeyExpression或partitionKeyExtractorClass在
生产者
中指定分区选择
Kafka
文档提到了循环分区。 s-c-s文档根本
没有
提到
spring
.
cloud
.
str
浏览 2
提问于2016-03-08
得票数 7
1
回答
Spring
不使用便携实现
、
、
问题似乎是,
Kafka
生产者
在主题中添加了项目名称作为前缀,而消费者不知道
这个
前缀。配置:
spring
.
cloud
.
stream
: output-products:
spring
.
cloud
.
stream
.
kafka
.binder.broker
浏览 4
提问于2021-01-18
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Cloud Stream简单入门
Spring Cloud Stream简介
微服务架构开发实战:SpringCloudBus的设计原理
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
译:基于Spring Cloud Stream构建和测试 message-driven 微服务
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券