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

Planned support for new Kafka 0.10 message format #642

Closed
makkes opened this issue Apr 14, 2016 · 3 comments
Closed

Planned support for new Kafka 0.10 message format #642

makkes opened this issue Apr 14, 2016 · 3 comments

Comments

@makkes
Copy link

makkes commented Apr 14, 2016

Do you already have plans on supporting the new message format of the upcoming 0.10 release? We're especially interested in using the new timestamps introduced with https://cwiki.apache.org/confluence/display/KAFKA/KIP-32+-+Add+timestamps+to+Kafka+message.

Thanks!

@wvanbergen
Copy link
Contributor

No plans as of yet, but we're always interested in contributions.

This may require #617 to be in place first, so we can continue to support older Kafka versions as well. @eapache what do you think?

@eapache
Copy link
Contributor

eapache commented Apr 14, 2016

There are two pieces here:

  • on-the-wire protocol message support, which we can add at any time and won't conflict with anything
  • ability to actually use the new messages in the producer/consumer which depends on User-space multi-version support #617 to really do properly

Pull requests welcome. I'll probably get around to it eventually otherwise, but it's very low on our list of priorities right now.

@eapache
Copy link
Contributor

eapache commented Jun 10, 2016

Support for targeting various kafka versions properly was done in #673 and #676. Support for producer timestamps was done in #678.

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