X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FNBI.git;a=blobdiff_plain;f=osm_nbi%2Ftests%2Fsend_kafka.py;fp=osm_nbi%2Ftests%2Fsend_kafka.py;h=d066d14303f71847aefd92132ba423f75a201129;hp=68356541e4c4168c52e16c479c57fff26be9ecd2;hb=4568a372eb5a204e04d917213de03ec51f9110c1;hpb=786aeddab7b7491a139c958ecec6439bee5da83a diff --git a/osm_nbi/tests/send_kafka.py b/osm_nbi/tests/send_kafka.py index 6835654..d066d14 100755 --- a/osm_nbi/tests/send_kafka.py +++ b/osm_nbi/tests/send_kafka.py @@ -40,13 +40,17 @@ if __name__ == "__main__": exit(0) if len(sys.argv) != 4: - print("missing parameters. Type --help for more information", file=sys.stderr) + print( + "missing parameters. Type --help for more information", file=sys.stderr + ) exit(1) topic, key, message = sys.argv[1:] host = getenv("OSMNBI_HOST", "localhost") port = getenv("OSMNBI_PORT", "9999") - url = "https://{host}:{port}/osm/test/message/{topic}".format(host=host, port=port, topic=topic) + url = "https://{host}:{port}/osm/test/message/{topic}".format( + host=host, port=port, topic=topic + ) print(url) data = {key: message}