你可以试着用 Record Oriented 处理器，即 PublishKafkaRecord_1.0 处理器。
因此，您的流程将是：

1.ListFile
2.FetchFile
3.PublishKafkaRecord_1.0 //Configure with more than one concurrent task

通过使用这个流，我们不会使用 SplitText 处理器和定义 RecordReader/Writer 中的控制器服务 PublishKafkaRecord 处理器。 In addition 也可以使用 Remote Process Groups 流量：

1.ListFile
2.RemoteProcessGroup
3.FetchFile
4.PublishKafkaRecord_1.0 //In scheduling tab keep more than one concurrent task

有关设计/配置上述流程的更多详细信息，请参阅此链接。
从nifi-1.8版本开始，我们不需要使用 RemoteProcessGroup （分配负载）因为我们可以配置连接（关系）来分配负载平衡。
请参阅此链接和nifi-5516链接以了解有关这些的更多详细信息 new additions 在nifi-1.8版本中。