小编der*_*rry的帖子

我有一个以byte []为关键字的主题，我想对其重新分区并通过邮件正文中字段中的另一个关键字来处理该主题。

我发现有KGroupedStream和groupby功能。但是它要求聚合函数转换为KTable / KStream。我不需要汇总。我只想重新分区并处理输出。