java - Kafka流返回所有记录，其中fieldx =某个值

您应该在“ customerID”上对订单流进行分组，并将所有订单汇总到一个列表中。结果KTable将具有<CustomerId, [List of Order]>类型事件。

使用交互式查询，您可以查询状态存储，

StreamsBuilder builder = new StreamsBuilder();
KStream<String, Order> orderStream = builder.stream("orders");
KTable<String,ArrayList<Order>> orderTable = orderStream
      .groupBy((key,value)-> value .get("customerId"))
      .aggregate(()-> new ArrayList<Order>(),
                 (key,val,agg)-> agg.add(val),
                  Materialized.as("customer-orders")
                  .withValueSerde(ArrayListSerde())          
       ); 

它将创建一个物化视图“客户订单”，您可以通过其余端点进行查询。

您可以点击以下链接将KTables公开为休息端点：

https://docs.confluent.io/current/streams/developer-guide/interactive-queries.html