yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-11-02 11:49:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix Kafka topic name for MCE ingestion CLI

Browse Source
This commit is contained in:
Kerem Sahin 2019-09-01 16:15:11 -07:00
parent 3702cdd888
commit 216e24c164
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
metadata-ingestion/src/avro_cli.py
View File

@ -91,15 +91,15 @@ def main(args):
if __name__ == '__main__':
parser = argparse.ArgumentParser(description="Client for handling Avro MetadataChangeEvent_v4")
parser = argparse.ArgumentParser(description="Client for handling Avro MetadataChangeEvent")
parser.add_argument('-b', dest="bootstrap_servers",
default="localhost:9092", help="Bootstrap broker(s) (localhost[:port])")
parser.add_argument('-s', dest="schema_registry",
default="http://localhost:8081", help="Schema Registry (http(s)://localhost[:port]")
parser.add_argument('-t', dest="topic", default="MetadataChangeEvent_v4",
parser.add_argument('-t', dest="topic", default="MetadataChangeEvent",
help="Topic name")
parser.add_argument('mode', choices=['produce', 'consume'],
help="Execution mode (produce | consume)")
parser.add_argument('-g', dest="group", default="MetadataChangeEvent_v4",
parser.add_argument('-g', dest="group", default="MetadataChangeEvent",
help="Consumer group; required if running 'consumer' mode")
main(parser.parse_args())