Add example listing committed offsets and lag#909
Conversation
Magnus Edenhill (edenhill)
requested review from
Matt Howlett (mhowlett) and
Ryan P (rnpridgeon)
Magnus Edenhill (edenhill)
force-pushed
the
offex
branch
from
d87e6d6 to
0ff7f9e
Compare
Ryan P (rnpridgeon)
left a comment
Ryan P (rnpridgeon)
left a comment
There was a problem hiding this comment.
I'm a bit confused by this example. It seems to demonstrate how one might sidestep limitations in the admin client. Does this belong in an FAQ instead? Ideally this functionality would come to through the admin client and then an example of such.
| import confluent_kafka | ||
|
|
||
|
|
||
| if len(sys.argv) < 4: |
There was a problem hiding this comment.
Why not just use argparse like the existing examples?
There was a problem hiding this comment.
Keeping it simple.
4 examples use sys.argv, 6 use argparse.
That's a much bigger task, including adding new APIs to librdkafka and the Python client, so until then we need to explain how to go about getting this information using what is available, since we get this question quite frequently. |
2 participants
No description provided.