KTable<String, Integer> highestProfit = profitperItem.toStream().groupByKey(Grouped.with(Serdes.String(),Serdes.Integer())).reduce((aggValue, newValue) -> Math.max(aggValue, newValue));