kafka4s-使用Kafka和Scala进行函数式编程 kafka4s提供了纯净，参照透明的功能来使用Kafka，并与和等FP库集成。 快速开始 要在具有Scala 2.12或更高版本的现有SBT项目中使用kafka4s，请根据需要将以下依赖项添加到build.sbt ： libraryDependencies ++ = Seq ( " com.banno " %% " kafka4s " % " " ) 注意：如果您的项目使用fs2 1.x，则需要2.x系列的发行版。 对于fs2