Versions in this module Expand all Collapse all v1 v1.11.0 Mar 7, 2019 v1.10.1 Feb 21, 2019 v1.10.0 Feb 15, 2019 v1.9.0 Jan 21, 2019 v1.8.2 Nov 28, 2018 v1.8.1 Nov 23, 2018 v1.8.0 Nov 13, 2018 v1.7.0 Sep 19, 2018 Changes in this version + func CreateConsumer(logger *zap.Logger, metricsFactory metrics.Factory, ...) (*consumer.Consumer, error)