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

produce does not have timestamp #7

Open
9il opened this issue Mar 28, 2017 · 7 comments
Open

produce does not have timestamp #7

9il opened this issue Mar 28, 2017 · 7 comments
Assignees

Comments

@9il
Copy link
Contributor

9il commented Mar 28, 2017

D wrapper as CPP wrapper successor uses rd_kafka_produce instead of new variadic interface that have timestamp support.

@yannick
Copy link
Contributor

yannick commented Mar 28, 2017

and is it a problem to use producev?

@9il
Copy link
Contributor Author

9il commented Mar 28, 2017

No problem

@9il
Copy link
Contributor Author

9il commented Mar 28, 2017

It is just porting artifact.

@9il
Copy link
Contributor Author

9il commented Mar 28, 2017

The prototype will look like:

ErrorCode produce(Topic topic, int partition, void[] payload,
        const(void)[] key = null, 
        long timestamp = Clock.currTime(UTC()).toUnixTime!long,
        int msgflags = MsgOpt.copy, void* msg_opaque = null)

with default parameter: long timestamp = Clock.currTime(UTC()).toUnixTime!long.

@yannick
Copy link
Contributor

yannick commented Mar 28, 2017

yep please port

@yannick
Copy link
Contributor

yannick commented Apr 8, 2017

@9il is this in now?

@9il
Copy link
Contributor Author

9il commented Apr 8, 2017

No, I commented this change because it does not work. Will update examples first, and then try again.

@9il 9il self-assigned this Apr 8, 2017
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

No branches or pull requests

2 participants