代码之家 › 专栏 › 技术社区 › Suanmeiguo

如何截断KTable

linktable apache-kafka-streams apache-kafka

Suanmeiguo · 技术社区 · 6 年前

我有一个卡夫卡流应用程序,利用KTable。我的应用程序已经运行了一段时间,所以KTable已经建立起来了。

如何截断KTable(假设我的应用程序可以处理重建表)?

停止我的应用程序并同时从changelog主题中删除数据是否正确?这似乎有点复杂,我觉得应该有一个更简单的方法。

1 回复 | 直到 6 年前

Matthias J. Sax 6 年前

如果要重新创建 KTable 从头开始,您可以使用应用程序重置工具。这可能是你的一个选择。

应用程序重置工具将删除为应用程序ID创建的所有更改日志和重新分区主题,因此对于新运行,您将获得新的

推荐文章

yershalom · 同一消费群体中具有不同分区数量的不同卡夫卡主题

2 年前

Oskars Apinis · 将kafka从服务器迁移到docker容器

2 年前

Sravan Kumar · Apache kafka模式注册表问题

2 年前

Panadol Chong · 无法建立到节点1(localhost/127.0.0.1:9092)的连接。经纪人可能不在。甚至传入正确的端点[重复]

2 年前

MrSham · 如何确保旧版本0.10.0在卡夫卡中只处理一次

2 年前

TheTags · Kafka-PLC4X-Modbus/TCP-作业刮取期间异常

3 年前

Iheb Mar · 卡夫卡制作人/消费者粉碎每一秒的API调用

3 年前

hasherBaba · 在为Nifi编写流媒体服务时,如何解决Java的空指针异常?[闭门]

6 年前

phaigeim · 为storm consumer检查卡夫卡主题的偏移量

6 年前

Raman · Kafka流:POJO序列化/反序列化

6 年前