Loading src/telemetry/backend/tests/messagesBackend.py +0 −17 Original line number Diff line number Diff line Loading @@ -13,20 +13,3 @@ # limitations under the License. def create_kafka_config_a(bootstrap_server: str, exporter_endpoint: str, kafka_topic: str, run_duration: int, fetch_interval: int): """ Provide ... Bootstrap_server IP address as String. Exporter endpoint with port <http://ip:port(metrics)> address as String. Kafka topic name as String. Total duration of the test as Int. Fetch_interval as Int. """ _bootstrap_servers = bootstrap_server _exporter_endpoint = exporter_endpoint _kafka_topic = kafka_topic _run_duration = run_duration _fetch_interval = fetch_interval return _bootstrap_servers, _exporter_endpoint, _kafka_topic, _run_duration, _fetch_interval Loading
src/telemetry/backend/tests/messagesBackend.py +0 −17 Original line number Diff line number Diff line Loading @@ -13,20 +13,3 @@ # limitations under the License. def create_kafka_config_a(bootstrap_server: str, exporter_endpoint: str, kafka_topic: str, run_duration: int, fetch_interval: int): """ Provide ... Bootstrap_server IP address as String. Exporter endpoint with port <http://ip:port(metrics)> address as String. Kafka topic name as String. Total duration of the test as Int. Fetch_interval as Int. """ _bootstrap_servers = bootstrap_server _exporter_endpoint = exporter_endpoint _kafka_topic = kafka_topic _run_duration = run_duration _fetch_interval = fetch_interval return _bootstrap_servers, _exporter_endpoint, _kafka_topic, _run_duration, _fetch_interval