java - Java中列表的动态过滤

Question

我正在开发一个从源接收实时数据(Kafka/Kafka Streams)的java应用程序。在我的案例研究中，我需要过滤列表中的名称。该列表最初有 1000 万个名字。

我的第一个问题是知道什么是最好的方法和/技术来获得更高效/更快的处理时间。

第二个问题是如何更新或删除列表中的某些名称？

Answer 1

need to filter the names that is part of my list

Kafka Streams DSL 有一个 filter() 函数。

how to update or delete some names in the list

不清楚“您的列表”存在于何处。

Kafka 主题本身不进行更新/删除，因为它们只能追加。 KTable 的操作和更新是通过发送匹配的键和新值来完成的；删除是通过匹配的键和空值完成的。