本机不存在这样的工具，但是您可以使用apache camel这样的工具轻松地完成这项工作，apache camel是一个成熟的路由库，完全是为这类任务而构建的。在这里，您将使用包含批量记录的一个主题，进行拆分并使用拆分的记录重新发布到另一个主题。使用java dsl，代码如下所示：

from("kafka:brokerHost:9092?topic=records-bulk&groupId=testing&autoOffsetReset=earliest&consumersCount=1")
    .split(body(String.class).tokenize("\n"))
    .to("kafka:brokerHost:9092?topic=records-individual");

上面的示例使用camel-kafka组件，并将每一行视为一个单独的记录，但是有许多其他方法可供选择来分割有效负载。开始使用camel最简单的方法是通过一个包含apachecamel的spring启动项目—这将允许您构建一个独立的可执行文件，您可以将它放置在与代理相关的任何位置。