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

Afkak does not set creation timestamps in kafka messages #38

Closed
scottmbaker opened this issue Sep 20, 2018 · 1 comment · Fixed by #134
Closed

Afkak does not set creation timestamps in kafka messages #38

scottmbaker opened this issue Sep 20, 2018 · 1 comment · Fixed by #134

Comments

@scottmbaker
Copy link

We've noticed that our kafka messages arriving with time=-1. We were able to work around this by changing our kafka brokers' log.message.timestamp.type setting from the default of CreateTime to LogAppendTime. However, we'd prefer that kafka messages get stamped with the creation time, which we believe requires changes to the producer client.

@twm
Copy link
Collaborator

twm commented Sep 20, 2018

Yes, this is a missing feature. Afkak currently produces to the broker using Message/MessageSet v0, which does not include a timestamp. We have work planned to implement Message/MessageSet v1 and Record/RecordBatch (which replace Message/MessageSet), but I don't have a timeline for it. Coordinated consumers are higher priority for us.

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

Successfully merging a pull request may close this issue.

3 participants