Resetting utils subtree.

2024-12-25 11:45:58 +05:30
parent bedf7da07d
commit 7005ab5a8d
172 changed files with 856 additions and 136761 deletions
@@ -90,7 +90,7 @@ from shared import constants
 if __name__ == "__main__":

    # Define the test params:
-    TOPIC = "kft_file_upload"
+    TOPIC = "tickers"
    BOOTSTRAP_SERVERS = "del.ditscentre.in:9092"
    SSL_CONTEXT = get_ssl_context(
        ca_file = os.path.join(constants.CREDENTIALS_DIRECTORY, "kafka", "cert_authority.pem"),