从Kafka state store中删除记录是否也会从changelog主题中删除该记录？
我们有一个Kafka流聚合拓扑。我们需要控制changeLog主题的大小，以减少Kafka存储成本。因此，我们在拓扑中使用transformer（DSL API）调度标点符号，该标点符号使用KeyValueStore.delete（）从stateStore中删除旧记录。
我能够验证在删除之后，在进一步调度的标点符号触发器中，删除的键不在状态存储中。但是它是否也会从changeLog主题中删除该记录？更重要的是，它是否也减少了changeLog主题的大小，从而使Kafka存储成本得到控制？
共有1个答案
是，对状态存储的更改应用于changelog主题。
-
有没有办法从Kafka主题中删除单个记录？我知道有一个脚本kafka-delete-records.sh删除指定主题和分区上指定偏移量之前的记录，但是我希望能够删除我指定的偏移量上的记录。有办法做到吗？ 这不是在Java而是在裸露的Kafka实例上。
-
本文向大家介绍从表中删除记录，其中相关面试题，主要包含被问及从表中删除记录，其中时的应答技巧和注意事项，需要的朋友参考一下 尝试首先选择最大组，然后将其用作子查询。 编辑：
-
我正在寻找一种从Kafka主题中删除（完全删除）已消费记录的方法。我知道有几种方法可以做到这一点，例如更改主题的保留时间或删除Kafka logs文件夹。但我要寻找的是一种使用Java API删除某个主题的一定数量记录的方法，如果可能的话。 我试过测试AdminClient API，特别是AdminClient。deleteRecords（recordsToDelete）方法。但如果我没弄错的话，
-
我正在使用hibernate多对多的关联。我有3个表(STUDENT，COURSE和STUDENT_COURSE）。在3个表中，2个是主表，1个是提供关系的中间表。当记录从STUDENT中删除时，相应的映射将从Student_Course中删除。我的要求是它甚至应该从课程表中删除记录。考虑以下STUDENT_COURSE条目： 当从学生表中删除101时，上述表中的第一个条目被删除，但课程表中对应于
-
在我的项目中，我有两个实体与@OneTomany和@ManyToOne相关。看看这些照片- 我的问题-当我从供应品中删除记录时，也会从产品中删除记录，但我不会这样做。如果我删除CascadeType.All，然后重试此操作，将出现错误 com.mysql.jdbc.exceptions.jdbc4.mysqlintegrityConstraintViolationException：无法删除或更新
-
有人有更好的主意吗？