1050. KTable - dkkahm/study-kafka-with-spring GitHub Wiki

groupByKey and aggregation

groupBy and aggregation

    feedbackStreams[0].groupBy((key, value) -> value).count()

topic as KTable

    flashSaleVoteStream.to("t.commodity.flashsale-vote-user-item");

    builder.table("t.commodity.flashsale-vote-user-item", Consumed.with(stringSerde, stringSerde))