是否可以在数据消耗后从Kafka中删除数据？
是否可以在数据消耗后从Kafka中删除数据？
我正在使用Kafka和Zookeeper组合在2个节点之间交换一些数据。我在Kafka的内存方面遇到了问题，因为我要插入这么多数据。这样，我需要在使用Kafka后清理它们中的数据。这可能吗？
共有1个答案
您可以尝试更改保留时间。
kafka-topics.sh --zookeeper localhost:13003 --alter --topic MyTopic --config retention.ms=1000
但要确定，因为无论天气如何，消息都将被删除。
-
我正在做星火流媒体项目。从Kafka那里得到数据。我想限制Spark-Streaming消耗的记录。关于Kafka的资料非常多。我已经使用属性来限制Spark中的记录。但在5分钟的批处理中，我收到了13400条消息。我的星火程序每5分钟不能处理超过1000条消息。Kafka主题有三个分区。我的spark驱动程序内存是5GB，有3个执行器，每个3GB。如何限制Kafka在spark Streamin
-
在Pyspark中执行映射函数时，我经常希望删除映射函数失败的数据（在本例中，转换为xml）。我想知道在映射步骤中是否有一个干净的方法来实现这一点？ 返回blank的明显解决方案仍然会在RDD中保留一个对象。 创建一个聪明的筛选器是浪费我的时间，而像try/except on这样的哑筛选器是浪费计算时间，因为我会对XML进行两次解析。
-
我刚加入弹性搜索公司。我正在想办法从ElasticSearch中删除数据。我已经删除了我的索引。然而，这似乎并没有真正删除数据本身。我看到的其他内容指向Delete by Query特性。然而，我甚至不确定该查询什么。我知道我的索引。从本质上说，我想弄清楚如何做一个 来自Chrome版邮递员。但是，我没有什么运气。好像不管我做什么，数据都挂在那里。到目前为止,我已经通过使用PostMan中的DEL
-
本文向大家介绍将数据写入块后是否可以更改数据？相关面试题，主要包含被问及将数据写入块后是否可以更改数据？时的应答技巧和注意事项，需要的朋友参考一下 回答：不，这是不可能的。如果需要进行任何修改，组织也必须从所有其他模块中删除信息。
-
我正在尝试做一个Java线程，这个线程必须从一个MySQL数据库中删除所有的记录，超过7天。 在我的表中，我有一列包含如下日期:。
-
我正在做一个聊天应用程序我想让用户能够删除聊天和消息从firebase数据库下面是我尝试使用一些代码删除消息适配器的代码，当我长时间点击消息，但当我登录到应用程序的消息回来。我使用firebase数据库