reugn /go-streamsGo2.2K172A lightweight stream processing library for Gostream-processingpipelineetlkafka