We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 60b8feb commit 654e069Copy full SHA for 654e069
examples/adminapi.py
@@ -862,9 +862,9 @@ def example_delete_records(a, args):
862
for partition, fut in futmap.items():
863
try:
864
result = fut.result()
865
- if result.err:
+ if result.error:
866
print(f"Error deleting records in topic {partition.topic} partition {partition.partition}" +
867
- f" before offset {partition.offset}: {result.err}")
+ f" before offset {partition.offset}: {result.error.str()}")
868
else:
869
print(
870
f"All records deleted before offset {partition.offset} in topic {partition.topic}" +
0 commit comments