1回答
我只想在发送所有记录之后确认偏移量，而不是在每条记录之后。/docs.spring.io/spring-cloud-stream/docs/current/reference/htmlsingle/index.html#_usage_examples)，但它确认每个记录之后的偏移量System.out.println("Acknowledgment provided");
acknowledgment.acknowl
浏览 18提问于2019-09-10得票数 0
1回答
在文件中：手册:消息侦听器负责确认()确认。然后，应用与批处理相同的语义。如果偏移量是在对轮询()返回的所有记录都进行了处理后提交的，那么我就不知道两者之间的区别了，您能给出手动ack模式被不同使用的场景吗？如果我使用手动模式，并且我没有在我的KafkaListener中调用KafkaListener，那么它将与批处理模式相同吗？如果我给acknowledge()打电话，会发生
浏览 3提问于2021-08-31得票数 3
回答已采纳
1回答
isolation.level = read_uncommitted因为我没有调用acknowledgment.acknowledge()，所以我希望偏移量不会被提交我也希望能多次收到相同的消息，但这并没有发生。只有当我重新启动整个应用程序时，它才会收到相同的消息。为什么会这样呢？我不是应该多次收到相同的消息吗？我确定偏移量没有被提交，因为当我重新启动应用程序时，我再次收到消息。那么，还发生了什么呢？
我注意到，如果我在"
浏览 0提问于2021-06-08得票数 0
这是基于给定主题的分区数量
现在，如果我需要横向扩展，我如何在多个应用服务器节点上分配属于同一组的消费者。而不需要多次阅读相同的消息。
浏览 5提问于2020-06-30得票数 1
我注意到了春季卡夫卡即将推出的一个功能：手册:消息侦听器负责确认()确认。然后，应用与批处理相同的语义。
在我看来，在批次中的所有记录都被确认之前，提交将永远不会发生。在侦听器成功生成消息之前，我不希望提交偏移量。确保这一点的自然方法是在onSuccess方法中发送由kafkaT
浏览 3提问于2021-08-26得票数 0
1回答
现在，说到提交模式。我真的不想手动指定偏移量，但我也不想使用自动提交，因为在从Kafka收到数据后，我需要做一些处理。使用这种解决方案，我预计会出现“不同消费者接收的相同数据”问题，因为我在读取(消费)之前没有指定偏移量，并且我同时从不同的客户端读取数据。
现在，我的问题是:消除多次读取的解决方案是什么？在一个消费者提交read之前，没有其他消费者访问Kafka。2)在每次读取之前以某种方式指定偏移量。我甚至不知道如何在</e
浏览 10提问于2018-02-01得票数 0
当我手动确认消费者应用程序中的偏移量时，我希望消费者可以自动重新获得未确认消息，但我不能成功。
浏览 1提问于2017-01-25得票数 0
1回答
弹簧-卡夫卡偏移表演方式
、、、
向我们提供了以下有关开始抵消的信息：
BATCH -当处理了轮询()返回的所有记录时，提交偏移量。TIME -提交偏移量时，在超过上次提交后的ackTime之前，轮询()返回的所有记录都已被处理。COUNT -提交偏移量，只要上次提交后收到ackCount记录，由轮询()返回的所有记录都已被处理。
COU
浏览 0提问于2017-10-16得票数 5
1回答
卡夫卡用户手动抵消提交
、、、
我希望在成功操作后手动提交偏移量，以避免任何数据丢失。我使用autoCommit: false来避免在消费后自动提交数据。 { topic: 'topic-A', partition: 0, offset: '1' }正如我在某个地方所读到的，如果我们有意地提交每个偏移量(在合并后<
浏览 3提问于2021-08-29得票数 5
如果消息发送到rest-end点失败，则不应提交偏移量，需要根据可配置的次数重试发送消息。在可配置的重试次数后，如果发送消息失败。我需要记录异常的原因并提交偏移量。以下是我的手动确认配置 spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.enable-auto-commit并且还能够手动确认来自不同消费者的偏移。logger.
浏览 83提问于2019-02-12得票数 2
回答已采纳
1回答
使用发布/订阅如何确认消息？
当消息被发送到特定组中的一些消费者时。这是否意味着，如果所有消费者确认了消息，还是所有消费者确认了消息？
浏览 2提问于2020-05-17得票数 1
回答已采纳
1回答
整个文档没有给出如何使用API提交/列表偏移量的明确示例 CursorServiceClient csc =
CursorServiceClient.create
浏览 14提问于2022-08-11得票数 0
我们正在尝试编写一个与Embedded Kafka from spring-kafka-test的集成测试，通过手动读取消费者组偏移量，使用admin client，在测试向我们的主题发送消息之前和之后使用awaitility，我们现在等待10秒来轮询偏移量，这似乎绕过了我们的大多数问题，因为偏移量将在大约7秒后发生变化-但这对于测试来说并不令人满意。有没有办法确保Spring Cloud Stream Kafka绑定器在我们通过调用Acknowledgement.acknowledge()手动<
浏览 15提问于2019-07-01得票数 1
回答已采纳
1回答
现在，如果所有重试都失败了，那么在这种情况下如何进行确认工作。另外，如果我已将确认模式设置为手动，那么如何确认这些消息 消费者 @Bean("kafkaListenerContainerFactory")
public ConcurrentKafkaListenerContainerFactory
浏览 50提问于2019-04-03得票数 2
回答已采纳
1回答
在下游系统不可用的情况下，消费者不要确认Kakfa消息。因此，当我的消费者在下游系统不可用时收到消息时，kakfa的偏移量将不会被提交。但如果我在下游系统启动后收到新消息，并且当我确认该消息时，最新的偏移量将被提交，消费者将永远不会收到没有偏移量提交的主题中的那些消息。
也就是说，假设我的消费者被消耗到偏移量4。当下游不可用时，消费者收到两条消息，因此我的消费者没有提交偏移量。因此
浏览 17提问于2019-08-01得票数 0
1回答
我有一个表单，需要在表单提交后继续确认。该表单有多个操作(如“修复”和“出售”)，在请求确认之前首先计算一些内容。我在考虑将request.POST临时存储在会话中，同时向用户询问确认信息。但是，我希望将确认信息放在一个类似警报的弹出窗口中，而不是呈现一个全新的页面。向您致以亲切的问候，汉斯
浏览 0提问于2014-07-14得票数 0
1回答
我只想在批处理成功保存到数据库后才更新提交偏移量。我尝试将确认对象传递给缓存服务，以调用如下所示的应答方法。：自动提交是错误的：即使调用了应答方法，也不会更新提交
浏览 0提问于2019-01-26得票数 2
有人能帮助我理解为什么当异常发生时，KafkaListener会重新处理手动并立即提交的消息偏移量吗？因此，我期待着以下行为：不知道我的理解是否正确？或者Spring会回滚我们在异常情况下所做的手动确认吗？
浏览 16提问于2022-07-14得票数 1
回答已采纳
2回答
我希望只在消息处理成功时使用spring云流手动提交偏移量。这是我的代码- application.yml & Handler类 consumer:但是我的确认对象是空的如何获得确认对象？--我的要求是，只有在处理成功时，才提交偏移
浏览 3提问于2021-02-08得票数 2
回答已采纳
我对这个特性的苦苦寻找在令人厌恶的日志问题：中得到了充分的描述，它显示了我多次尝试不同的失败。如何订阅ReactiveKafkaConsumerTemplate<String, String>，它将以同步的方式处理记录(为了简单起见)，并将每2秒确认/提交一次，并在手动取消流时？即。它工作，每隔2秒确认/提交一次。然后通过rest/jmx/无论什么来的信号，流终止并确认/提交最后处理的kaf
浏览 0提问于2021-02-28得票数 0
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
