This repository has been archived by the owner on Oct 2, 2020. It is now read-only.

TLS options is not correctly handled #78

Open

Gillani0 opened this issue Oct 3, 2019 · 0 comments

Gillani0 commented Oct 3, 2019

Hi,
Even if there is TLS options available in kafka.ConsumerConfig. It's not taken into account for sarama config.

This requires a patch in newConsumerBuilder and buildOptions function:

`if config.TLSConfig != nil {
	opts.TLSConfig = config.TLSConfig
       }
`

The text was updated successfully, but these errors were encountered:

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.