回答情况：
提问时间：
问题标签：
用户调用Service-A的REST端点，后者进行处理，在数据库中创建记录/条目，然后发送Kafka事件，以便可以使用Service-B。我用@Transactional进行了注解，这样数据库提交和Kafka提交就会同时发生。 服务B将接收Kafka事件，处理并将更新后的事件发送回服务A。由于ChainedKafkaTransactionManager已被弃用，我如何确保先提交数据库，再提交Kafka？ 对于生产者启动的事务，在事务同步的情况下，Kafka提交
浏览 17修改于2021-09-04得票数 0
回答已采纳
1回答
我有一个用例，在这个用例中，我需要从一个kafka主题中消费，做一些工作，生成另一个只具有一次语义的kafka主题，并将其保存到一个mongo数据库.After中，通过文档，我认为可以同步卡夫卡事务和mongo事务，但它们仍然是两个不同的事务，.In，如果mongo提交失败了，那么有一种方法可以回滚提交到该主题并从消费者处重放的kafka记录。
浏览 1提问于2018-08-08得票数 2
回答已采纳
1回答
我在事务API中找不到答案。我认为在引擎盖下看设计可能是不可能的，但我想确认一下:如果消费者和生产者连接到不同的Kafka集群，那么有可能进行Kafka交易吗？这意味着我正在消费的主题和我正在推送的主题是在两个独立的Kafka集群上。
浏览 20提问于2019-04-26得票数 2
回答已采纳
1回答
我遵循 Spring-cloud-stream-kafka模板，但在制作producer方法transactional时被卡住了。我以前没有使用过kafka，因此需要帮助，以防kafka中需要任何配置更改。如果没有添加事务性配置，它会运行良好，但是当添加事务性配置时，会在启动时超时--
2020-11-21 15:07:55.349 ERROR 20432 --- [ main] o.s.c.s.b.k.p.KafkaTopicProvisioner: Failed to obtain
浏览 5修改于2020-11-24得票数 0
回答已采纳
我正在使用2.2.2.RELEASE(org.apache.kafka:kafka-clients:jar:2.0.1)和spring(2.1.1)。我无法执行事务，因为我的侦听器无法获得分配的分区。我正在尝试配置事务性侦听器容器，并且只需要一次处理
我使用事务管理器配置了生产者和使用者，用事务id配置了生产者，用isolation.level=read_committed配置了使用者。transaction; nested exception is org.apache.kaf
浏览 0修改于2019-07-22得票数 1
我正在读关于Kafka事务数据流的文章，有一件事我不清楚，那就是协调器将WriteTxnMarkerRequest发送给每个分区的领导者之后会发生什么。如果是这样，它是否只是将最终提交或中止消息写入事务日志？
浏览 15修改于2019-10-25得票数 0
回答已采纳
我有一个用例，在这个用例中，我需要向单个事务中的3个不同主题发送3条消息。问题是其中一个主题是紧凑的，我对Kafka交易非常陌生，所以我不太确定事务取消是如何工作的。我的问题是:如果事务失败或中止(应用程序崩溃、异常等)，实际会发生什么？是否最终会从压缩主题的日志中删除中止事务的记录(比如空记录)？非压缩主题也是一样的吗？
谢谢。
浏览 3修改于2021-04-26得票数 0
回答已采纳
我需要使用consume process-produce模式来处理Kafka消息，并配置了一个带有Kafka事务管理器的Spring Kafka侦听器容器，还设置了transaction-id-prefix来启用Kafka事务。我使用了批处理的ack-mode，并试图了解在这种事务模式下，何时会实际提交偏移量。文档似乎表明，一旦使用了轮询中的所有记录，ack-mode批量提交偏移量-在事务上下文中也是如此，即每个轮询1个事务？或者在使
浏览 20修改于2020-03-12得票数 0
回答已采纳
我需要访问spring云流kafka事务性重试中的重试尝试号，这样对于特定的异常，基于重试尝试号，我可以将结果发布到不同的主题。
浏览 3提问于2022-09-27得票数 1
回答已采纳
我想实现模式，所以我需要Kafka事务。
要配置事务，我需要为每个Kafka生产者设置一些transaction id。那么，如何为Kubernetes中托管的几个应用程序选择Kafka事务id呢？
浏览 8提问于2019-07-24得票数 2
回答已采纳
我正在处理kafka用例，我需要在生产者和消费者端拥有事务性语义。我可以使用kafka transaction API0.11将事务性消息发布到kafka集群，但在消费者端我遇到了问题……我在属性文件中设置了isolation.level=read_committed;import org.apache.kafka.common.errors.OutOfO
浏览 5修改于2017-09-12得票数 2
我已经创建了一个事务性使用者，我希望确保我读取和处理一个主题的所有消息。如果交易失败，因此消息丢失，Kafka仍然提交偏移量。我认为，如果事务性使用者失败了，那么Kafka将回滚，但继续提交偏移量，以便它可以处理下一条消息。但是如果卡夫卡提交了偏移量，那么之前的信息就丢失了吗？spring.kafka.consumer.auto-offset-reset=earliestspring.kafka</em
浏览 0修改于2018-06-21得票数 5
回答已采纳
我们正在使用spring kafka streams来处理数据流。我们目前使用的是processing.guarantee: exactly_once配置，以确保它完全符合数据处理的一次性语义。拦截器使用kafka模板向kafka主题发布元数据(主要是略读消息的头部数据)。 将其放在拦截器上的原因是处理流的管道，包括多个应用程序/主题，并且很容易将拦截器连接到单独的应用程序。我的问题是，我的拦截器中使用的kafka模板是需要@ transaction注解还是使用由processing.gaurantee配置生成的
浏览 21提问于2021-06-24得票数 0
回答已采纳
我已经将PlatformTransactionManager设置为Kafka事务作为一个bean。我在方法级别使用了@Transactional注解。我们将在3个主题中发布消息。因此，这里的通话被打断了，但消息正在发布到Kafka。我们只是在产生信息。我们没有消费任何消息，但能够在我们内部的Kafka检查工具中看到消息。
浏览 49提问于2021-09-05得票数 0
我有一个只使用使用者的应用程序，它不断地从Kafka读取消息，处理消息，并使用Ack侦听器手动确认消息。我有一个上游生产者专用应用程序的依赖关系，它们负责向Kafka主题发送消息，以便我消费。我们最近实现了跨生产者和消费者的事务，但我想了解更多关于故障点的信息，以及如何处理那些回滚的事务，这样它们就不会丢失？我已经读到，对于kafka容器工厂上的事务，最好使用AfterRollbackProcessor而不是SeekToCurrentErrorHandler，并将StatefulRetr
浏览 2提问于2020-01-10得票数 2
回答已采纳
我目前正在创建一个Springboot应用程序，它将使用Kafka主题的消息，处理后将写回另一个主题。我用骆驼来整合。like this :
<groupId>org.apache.camel.springboot</groupId>
<artif
浏览 3修改于2021-05-17得票数 1
为了公平起见，我已经在没有事务方案的普通kafka中测试了它，当我多次尝试重新运行ProducerTest时，它不会跳过偏移量。:9092")
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer")props.put("value.serializer", "org.apache.kafka.common.serializ
浏览 1修改于2020-02-13得票数 0
我试图理解Kafka的事务性API。将原子读-进程-写入周期定义为：
在我的应用程序中，我只需使用kafka的消息，进行处理并将它们记录到数
浏览 7提问于2019-10-04得票数 4
我想将kafka事务与存储库事务同步：public void syncTransaction(){ kafkaTemplate.send如果我理解正确，kafkaTemplate和kafkaTransactionManager必须使用相同的producerFactory，其中我必须启用事务设置transactionIdPrefix。如果我能得到一个简单的kafka事务与存储库事务<
浏览 4修改于2020-10-22得票数 13
回答已采纳
我们有一个spring引导应用程序，它使用来自IBM的消息，进行一些转换，并将结果发布到Kafka主题。为此，我们使用。我知道Kafka不支持XA；但是，在文档中，我发现了一些关于使用ChainedKafkaTransactionManager链接多个事务管理器和同步事务的输入。同一文档还提供了一个示例，说明如何同步Kafka和数据库，同时读取Kafka的消息并将它们存储在数据库中。“如果事务是活动的，则在事务范围内执行的任何KafkaTemplate
浏览 3提问于2020-05-21得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号