为什么KafkaTransactionManager没有被应用到这个Spring Cloud Stream Kafka生产者？
KafkaTransactionManager没有被应用到这个Spring Cloud Stream Kafka生产者的原因可能是由于以下几个方面：
- 业务需求不需要事务支持：KafkaTransactionManager主要用于提供分布式事务的支持，保证消息的原子性提交和回滚。但在某些业务场景下，对于消息的一致性和可靠性要求并不高，因此不需要使用事务管理器。
- 系统架构选择不同：Spring Cloud Stream框架提供了灵活的消息中间件集成，而KafkaTransactionManager只是其中一种事务管理器实现。如果系统架构选择了其他消息中间件，例如RabbitMQ，那么就无法使用KafkaTransactionManager。
- Spring Cloud Stream版本兼容性：不同版本的Spring Cloud Stream和KafkaTransactionManager之间可能存在兼容性问题，导致无法正常应用。在使用过程中，需要确保版本的匹配性。
总结起来，KafkaTransactionManager没有被应用到该Spring Cloud Stream Kafka生产者，可能是因为业务需求、系统架构选择或者版本兼容性等原因所导致。如果具体的场景需要使用事务管理器，可以考虑使用其他可用的事务管理器，或者对Spring Cloud Stream框架进行自定义扩展以支持KafkaTransactionManager。
相关·内容
我已经配置了一个Spring Cloud Stream Kafka应用程序来使用事务(full source code available on Github)： spring: name: message-relay-service stream: binder:
浏览 23提问于2019-06-27得票数 0
回答已采纳
我们正在为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
回答已采纳
我试图包装一个rest服务调用，它使用JPA (CrudRepository.save)将记录保存到DB，然后使用StreamBridge使用spring云流(kafka binder)将消息发送到Kafka我试过几件事，但似乎没有什么效果很好。我故意造成JPA问题(插入违反唯一键约束的行)，但是Kafka消息似乎仍然传递给代理。我已经配置了一个KafkaTransactionManager (没有使用ChainedKafkaTransactionManager，因为现
浏览 2提问于2021-07-20得票数 4
回答已采纳
我正在运行Stream应用程序，在该应用程序中，我从Kafka主题读取事务，处理事务，然后将它们发送到IBM。当没有与IBM的连接时，我试图处理这个错误，以防止事务丢失。期望的行为是事务保持在Kafka主题中，而流侦听器再次读取它。然而，消息似乎只被消耗了一次，并且没有发生“回滚”。要做到这一点，以下是我的心声： cloud: kafka:
浏览 1提问于2019-08-02得票数 1
回答已采纳
我想在我的春季云流卡夫卡应用程序中为我的生产者设置acks=all属性。我试过这样做：和和
spring.cloud.stream.kafka.
浏览 1提问于2019-04-24得票数 1
1回答
我有多个生产者将消息推送到我的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回答
我正在尝试将生产者配置添加到我的项目中，使用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
我正在尝试通过Spring Cloud在一个事务中向Kafka中的两个单独的主题发送消息。当在第一条和第二条消息之间抛出异常时，第一条消息仍然出现在第一个主题的使用者中，表明消息没有回滚。tm = new KafkaTransactionManager<>(pf); }application.yml包含以下内容： stream:
bindin
浏览 0提问于2021-07-09得票数 1
1回答
弹簧云函数路由
、、、、
=falsespring.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
回答已采纳
)配置如下spring.cloud.stream.kafka.streams.bindings.responseo.producer.key-serde=org.springframework.kafka.support.se
浏览 2提问于2019-02-25得票数 0
回答已采纳
2回答
我已将我的生产者配置为：spring.cloud.stream.bindings.pc-abc-outspring.cloud.stream.bindings.pc-abc-out-0.producer.partition-count=10
spring.<e
浏览 8提问于2022-01-24得票数 2
回答已采纳
我只想把它放在一个消费者身上 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
回答已采纳
但是，没有管理属性。我想知道在设计时，是否有具体的原因没有考虑到管理属性。以下是我认为上述两种选择的一些缺点，
对于使用spring.cloud.stream.kafka.configuration.xxx，如果我只想将一些属性配置为admin，那么我还必须设置另外两个属性spring.cloud.stream.kafka.consumer-
浏览 27提问于2022-11-18得票数 1
使用spring-cloud-stream的kafka绑定器，如何配置并发消息消费者(在单个消费者jvm中)？如果我理解正确的话，使用kafka时使用并发消息消耗需要分区，但指出，要使用分区，您需要通过partitionKeyExpression或partitionKeyExtractorClass在生产者中指定分区选择Kafka文档提到了循环分区。
s-c-s文档根本没有提到spring.cloud.str
浏览 2提问于2016-03-08得票数 7
1回答
问题似乎是，Kafka生产者在主题中添加了项目名称作为前缀，而消费者不知道这个前缀。配置：spring.cloud.stream: output-products:
spring.cloud.stream.kafka.binder.broker
浏览 4提问于2021-01-18得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
