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

GlobalKTable是否总是每个分区键只有1条记录,即使记录的主题压缩没有启动?

夏新翰
2023-03-14

我有一个Kafka主题,通过设置“清理”启用了压缩。政策=紧凑。我的部分。字节属性设置为稍大一点的值(100Mb),这样我的代理运行良好。

如果我有一个Kafka流应用程序,它使用的主题是GlobalKTable,并且在主题中的单个分区键有多个记录,该应用程序将在GlobalKTable中只接收1个记录,还是在压缩开始之前有两个记录?

共有1个答案

邹开畅
2023-03-14

GlobalKTable中只有一条记录,因为默认情况下,表是RocksDB状态存储,这是一个键值存储。因此,即使主题中有多个键,表中也只有一个键。

 类似资料:
  • 我有一个spring实体类,如下所示。 具有相应的getter和setter。 我已经为这个表访问编写了一个Spring Data JPA存储库,如下所示。 但我想使用value读取所有记录。但不是主键。所以我想知道如何实现这一点。 有人能帮我一下吗。

  • 问题内容: 我有一个具有“约会表”和“服务表”的数据库。每个appt都有一个服务,每个服务都有一个价格。我想要的是一个查询,该查询将始终返回12行(每月一行),并包含几个月的总和(基于其服务ID)。到目前为止,我有: 当前,返回的内容如下: 问题是,如果一个月没有任何订单,我不会在查询中返回该月。我希望该月有一个记录,只是它的“ monthly_total”等于零。 以下是我希望查询返回的内容:

  • 问题内容: 一个活动有很多参与者。参与者的字段为“状态”。 我需要找到除以下事件以外的所有事件:每个参与者的状态都为“出席”的事件。 我可以找到带有以下AR代码的某些参与者处于“呈现”状态的所有事件: 这样就创建了SQL: 这 几乎 可行。问题是,如果参与者的某行(在范围内 )的状态为“离开”,则该事件仍将被获取,因为至少某些同级记录的状态与其他状态相同而不是“现在”。 我需要确保我正在过滤所有事

  • 我希望有、和,其中每一个都映射到Elastic Beanstatk上相同应用程序的单独环境。 这有可能吗? 在我的托管区域上,例如。com ,我已经为www.example设置了cname记录。com,登台。实例com和演示。实例com,每个都有一个指向各自的EB url的值。 第一个是我设置的www.example。com工作,请求到达环境。但是当我试图通过ping staging联系其他人时。

  • 我有下表: 我还有以下表: 现在我有以下疑问: 长话短说--我的目标是,给定值,从表中获取最新的值。 它应该是这样工作的:给定值-在表中搜索与相同值的匹配记录(注意此列是唯一的)。然后-在表中查找最新的值(使用值)。使用与表中的列匹配的列在此表中搜索它。 当前,该查询将返回,但不返回(我需要它是3030)。你能帮我修一下吗?

  • 由于我有几个主题,结果代码非常冗长: 如何通过配置注释的属性,使这种重复配置更加简洁?