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
Transfer command #30
Transfer command #30
Conversation
Still todo:
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please also run black with --line-length 119
. Would be cool if you could add that to travis as well.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
One minor comment. Otherwise approved.
Nice work and great code. 👍
number_consumed_messages = _consume_to_file(working_dir, topic, group_id, from_context, numbers, avro, last) | ||
|
||
if number_consumed_messages == 0: | ||
click.echo(click.style("Execution stopped, because no messages consumed.", fg="red")) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I would state the reason for stopping the execution. No consumption is the effect. This case is probably getting hit when the topic is empty or the starting offset was chosen to high, right?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
How would you do this? Maybe checking the high_watermarks for all topics as indicator for an empty topic? But with log retention it could also be empty with a high_watermark greater 0.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I didn't mean in that much detail.
The user can still find out what exactly the problem was by him/herself. You could just name the possible reasons in the error message.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
ah sure
No description provided.