Skip to content
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

The wiki of the offset API has been updated again #400

Merged
merged 1 commit into from
Mar 30, 2015
Merged

Conversation

eapache
Copy link
Contributor

@eapache eapache commented Mar 27, 2015

This should bring us up to date.
Version int16 // 0 (0.8.1 and later) or 1 (0.8.2 and later, includes timestamp field)
blocks map[string]map[int32]*offsetCommitRequestBlock
ConsumerGroup string
ConsumerGroupGeneration int32 // v1 or later
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Do you have any idea what this used for? Couldn't find anything useful in the wiki.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@yagnik
Copy link

yagnik commented Mar 28, 2015

minor comment other lgtm

@wvanbergen
Copy link
Contributor

This LGTM.

Not sure how long the approach of trying to support all version from one type is going to be sustainable, but for now :shipit:.

eapache added a commit that referenced this pull request Mar 30, 2015
The wiki of the offset API has been updated again
@eapache eapache merged commit 7c14172 into master Mar 30, 2015
@eapache eapache deleted the update-offset-API branch March 30, 2015 02:36
@jsvisa
Copy link

jsvisa commented Apr 1, 2015

@eapache @wvanbergen Seems Kafka 0.8.2 also not support OffsetManage. Before you send a OffsetCommitRequest, you need to send a ConsumerMetadataRequest to get the Coordinator, but this request always failed in kafka 0.8.2.0:

kafka server: Offset's topic has not yet been created. CoordinatorID:-1 CoordinatorHost: CoordinatorPort:-1

which is succeed in Kafka 0.8.2-beta.

@wvanbergen
Copy link
Contributor

@jsvisa It is working for me on 0.8.2.1 (see #379). The very first time you make this API call, Kafka first has to create the topic which takes some time. The only solution for that problem that worked for me is retrying often enough.

@jsvisa
Copy link

jsvisa commented Apr 1, 2015

@wvanbergen Thanks for your advise, I'll try it later in 0.8.2.1

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

Successfully merging this pull request may close these issues.

4 participants