java - 如何将KStream的Object类型的值存储在Hashmap中？

Question

我有一个 KStream 对象，如 KStream<String, Object> 。我想获取 HashMap 中对象的值并将其在不同的 KStream 中处理后存储为值？

例如，

KStream 键 =“第一”

KStream 值 = {id=1, name="abc"age=12}

期望的结果:HashMap hm ={id=1, name="abc"age=12}

Answer 1

您似乎对概念有一些误解。

KStream 是主题(以及其中的所有记录)的逻辑抽象。它允许您逐一处理这些记录。例如，您可以这样做:

KStream stream = builder.stream(...);
stream.foreach((k, v) -> { /* your processing logic */});

I want to fetch the value of the Object in a HashMap

您似乎希望在与 KStream 相同的范围内拥有一个 HashMap。但是，您无法从“外部”访问任何记录，只能通过将运算符(如上例所示的 foreach())应用于 KStream 来转换一个 KStream 到一个新的`KStream。

and store it as a value after processing in a different KStream

请注意这是什么意思。您可以通过对其应用运算符将​​一个 KStream 转换为新的 KStream。例如:

KStream result = kstream.map(...);

此程序将为 kstream 中的每条记录执行您传递给 map() 的函数，并将映射函数的结果记录附加到 result.即，map() 将每个输入记录转换为新的输出记录。

请注意，当您定义处理时，您基本上指定了一个在调用KafkaStreams#start()后连续执行的数据流程序。