Skip to content
This repository has been archived by the owner on May 13, 2019. It is now read-only.

Expose a way to set offset manager config #64

Open
aaronkavlie-wf opened this issue Jul 31, 2015 · 2 comments
Open

Expose a way to set offset manager config #64

aaronkavlie-wf opened this issue Jul 31, 2015 · 2 comments

Comments

@aaronkavlie-wf
Copy link
Contributor

While there are public methods for initializing the offset manager and its config, JoinConsumerGroup() does not make it possible to set this. It sets internally to a private member, offsetManager. I don't see a way to set VerboseLogging in the consumer group API.

@wvanbergen
Copy link
Owner

How would you want to initialize it?

@aaronkavlie-wf
Copy link
Contributor Author

Seems that an OffsetManagerConfig pointer would be at home in the Config struct in consumer_group.go, similar to the *kazoo.Config pointer.

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants