kafkadriver

func NewClient ¶

func NewClient(
	ctx context.Context,
	brokers []string,
	groupID string,
	config *sarama.Config,
	opts ...Option,
) (*Client, error)

NewClient returns *kafkadriver.Client, also connects to the kafka cluster.

This driver uses https://github.com/Shopify/sarama internally to connect to kafka brokers. A slice of broker addresses are required by sarama to connect to the kafka cluster, specify only one if single node. Configuration is handled bysarama.Config to subscribe to a kafka topic. https://godoc.org/github.com/Shopify/sarama#Config groupID is consumer group id. Additional configuration options can be added with kafkadriver.Option functions.