-
Notifications
You must be signed in to change notification settings - Fork 5.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Use sarama built in support for consumer groups #6172
Conversation
log.Printf("I! WARNING: Kafka consumer invalid offset '%s', using 'oldest'", | ||
k.Offset) | ||
config.Consumer.Offsets.Initial = sarama.OffsetOldest | ||
return fmt.Errorf("invalid offset %q", k.Offset) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is this something that will need to be documented upfront, as previously bad values would be set to a default?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think this change is okay, we always warned and the value was never valid.
4a2d3c6
to
a215be7
Compare
2b68c8a
to
15b999f
Compare
VERSION := $(shell git describe --exact-match --tags 2>nil) | ||
HOME := $(HOMEPATH) | ||
CGO_ENABLED ?= 0 | ||
export CGO_ENABLED |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Switched over to disabling CGO in Windows unless explicitly enabled. Not entirely sure this is a good idea but I'm trying to avoid the confusion of suddenly needing gcc to build.
Use sarama built in support for consumer groups instead of the, now deprecated, sarama-cluster library. Hoping this will help with #6136
Required for all PRs: