流媒体 使用NFJS中的Kafka从我的流架构演讲中获得的源代码 要运行这些代码示例，您将需要Java 1.8，Kafka（10.2）和最新的Zookeeper安装（docker也可以工作）。 如果您不想打扰用于交易验证服务的RabbitMQ代码，只需删除交易生成器中的调用即可。 如果要运行脚本，则需要设置环境变量STREAMING_HOME，该变量指向包含类文件和库所在的src和lib目录的目录。