当前位置: 首页 > 知识库问答 >
问题:

关于对多个主题使用@kafkalistener autoStartup=“false”的问题

汪理
2023-03-14

++++++++++++++++++++++++++++++++++++

编辑

运行以下测试,每个主题都有一个分区。在测试运行之前,topic1中有10条消息,Topic2中有10条消息。运行代码并让10条topic1消息得到处理,但是当topic2消息得到处理时,我向topic1发送了更多的消息,但在处理完来自topic2的所有预先存在的消息之前,监听器没有处理这些消息。

共有1个答案

吕永寿
2023-03-14

没有这样的保证。

请参见此问题的答案。

Kafka只保证消息在分区内排序。...

 类似资料:
  • 上图是一个 wordpress 主题的文件部分结构 一直弄不懂 front-page.php, home.php 这两个文件到底有什么区别? 都是代表首页吗? home.php 和 single.php 又有什么区别? 如果查看单篇文章会进入 single.php, 那 home.php 为什么会被叫做文章页? 文件有点混淆, 求大佬指点指点..

  • 我用亚马逊云的Lambda函数,通过langChain调用OpenAI API。我把OPENAI_API_KEY存在了Lambda函数的环境变量里了。神奇的是,在创建new ChatOpenAI()实例的时候没有传入OPENAI_API_KEY,还是可以获取到正确的返回值。这是为什么?

  • 我目前正在尝试用cubey地形制作一个基本游戏,类似于Minecraft classic。我的第一个问题: 如何在VBO中存储多维数据集列表,然后在更改该数据时重新生成该列表?我当前呈现的立方体如下所示: 我知道我需要使用和来修改VBO,但是如何存储多维数据集并在需要时删除它们?我应该使用ArrayList吗?另外,有人告诉我,我渲染立方体的方式是错误的,因为每个人都说我只渲染一个具有新坐标的立方

  • 代码: 结果: 代码在jdk1.7和jdk1.8中执行相同的结果。 我的问题: > 线程 A 和线程 B 进入 SYNCHRONIZED 块并调用 wait() 方法后,为什么线程 C 和线程 D 进入而不是线程 A 说 i,然后线程 B 说 i?输入同步块的优先级是否高于刚刚调用 wait() 方法的线程? 为什么调用通知()方法只是唤醒调用等待()方法的最后一个线程?就像线程C和线程D一样,相

  • 本文向大家介绍关于多对多关系表无法更新与插入的问题,包括了关于多对多关系表无法更新与插入的问题的使用技巧和注意事项,需要的朋友参考一下 在EF里,我们设计模型时,会设计到多对多关系,在EF里会把这种关系会转成两个一对多的关系表,这是比较友好的,因为多对多来说,对于业务本身没什么意思,所以隐藏了,没什么坏处,但对于这个隐藏来说,对开发人员来讲你就无法主动控制这张关系表了,而需要使用EF的update

  • 为什么最后输出的是“WuffRingding”而不是“RingdingRingding”? 为什么最终输出是“颤动”而不是“振铃”?为什么最终输出是“颤动”而不是“振铃”?