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

OffsetCommit: Use the new broker offset request response for storing offsets #113

Closed
joestein opened this issue May 8, 2014 · 4 comments

Comments

@joestein
Copy link

joestein commented May 8, 2014

0.8.1.1 release is out would be cool to use broker to store offsets off to zookeeper https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetCommit/FetchAPI

@edenhill
Copy link
Contributor

master branch currently supports OffsetRequest and OffsetResponse.
Enable by setting offset.store.method=broker.

Full support for the new non-zk consumer group balancing will be available during the summer, most likely.

@austin0508
Copy link

Hello,the rdkafka still have't the function of consumer group ?

@edenhill
Copy link
Contributor

The full non-ZK support for consumer groups is scheduled for Apache Kafka 0.9 which is probably a couple of months out.
librdkafka will support it when Kafka 0.9 is released.

There will not be support for ZK-based consumer groups in librdkafka, but it can be implemented by the application on top of librdkafka and libzookeeper for the needy.

@edenhill edenhill changed the title Use the new broker offset request response for storing offsets OffsetCommit: Use the new broker offset request response for storing offsets Jul 20, 2014
@edenhill edenhill added this to the dev15_merge milestone Sep 8, 2015
@edenhill
Copy link
Contributor

Fixed on master

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

No branches or pull requests

3 participants