Kafka 流包含列表<Employee>，我想创建一个仅包含员工对象的解压缩输出流

Question

Kafka流包含一个List<Employee>，我想处理该流，因为新的Kafka stream将包含来自List<Employee>.的所有Employee

简而言之，我想从现有流中解压Employee List，并将单个Employees对象放入新的流中

我正在尝试使用Kafka Java库中的flatMapValues(K,V)函数。

基本上，我需要对List<Employee>进行解包，并将单个对象放入Kafka流中。

我也尝试过在Kafka流上使用forEach循环，但它不起作用。

我看到了使用flatMapValues()的文档，但不确定如何使用它

Answer 1

如果从flatMapValues函数返回列表，它将被扩展为单独的记录。

您可能需要添加一个Produced.withValueSerde，以便为各个对象而不是它们的列表设置适当的序列化程序。