diff --git a/tests/kafka_test.py b/tests/kafka_test.py index 98c1936..478a5b3 100644 --- a/tests/kafka_test.py +++ b/tests/kafka_test.py @@ -134,7 +134,7 @@ if __name__ == "__main__": while True: await asyncio.sleep(1.0) messages = await my_consumer.consume(count = 10, timeout = 1.0) - for message in messages: print(json.to_string(message["value"])) + for message in messages: print("MESSAGE:", json.to_string(message["value"])) async def main(): await asyncio.gather(*[keep_producing(), keep_consuming()]) diff --git a/utils_v2/cache/__pycache__/__init__.cpython-310.pyc b/utils_v2/cache/__pycache__/__init__.cpython-310.pyc index b168cc8..63bfb60 100644 Binary files a/utils_v2/cache/__pycache__/__init__.cpython-310.pyc and b/utils_v2/cache/__pycache__/__init__.cpython-310.pyc differ diff --git a/utils_v2/cache/__pycache__/async_redis_cache.cpython-310.pyc b/utils_v2/cache/__pycache__/async_redis_cache.cpython-310.pyc index 6a0d7d1..677dc6b 100644 Binary files a/utils_v2/cache/__pycache__/async_redis_cache.cpython-310.pyc and b/utils_v2/cache/__pycache__/async_redis_cache.cpython-310.pyc differ diff --git a/utils_v2/database/__pycache__/__init__.cpython-310.pyc b/utils_v2/database/__pycache__/__init__.cpython-310.pyc index e6bb512..fc51708 100644 Binary files a/utils_v2/database/__pycache__/__init__.cpython-310.pyc and b/utils_v2/database/__pycache__/__init__.cpython-310.pyc differ diff --git a/utils_v2/database/__pycache__/async_mongo_v2.cpython-310.pyc b/utils_v2/database/__pycache__/async_mongo_v2.cpython-310.pyc index 7128ae7..2f7d136 100644 Binary files a/utils_v2/database/__pycache__/async_mongo_v2.cpython-310.pyc and b/utils_v2/database/__pycache__/async_mongo_v2.cpython-310.pyc differ diff --git a/utils_v2/string/__pycache__/__init__.cpython-310.pyc b/utils_v2/string/__pycache__/__init__.cpython-310.pyc index 56c7f94..e6094e5 100644 Binary files a/utils_v2/string/__pycache__/__init__.cpython-310.pyc and b/utils_v2/string/__pycache__/__init__.cpython-310.pyc differ diff --git a/utils_v2/string/__pycache__/json.cpython-310.pyc b/utils_v2/string/__pycache__/json.cpython-310.pyc index 4d899fc..00bccbc 100644 Binary files a/utils_v2/string/__pycache__/json.cpython-310.pyc and b/utils_v2/string/__pycache__/json.cpython-310.pyc differ diff --git a/utils_v2/system/__pycache__/__init__.cpython-310.pyc b/utils_v2/system/__pycache__/__init__.cpython-310.pyc index aec6600..ba0ab2c 100644 Binary files a/utils_v2/system/__pycache__/__init__.cpython-310.pyc and b/utils_v2/system/__pycache__/__init__.cpython-310.pyc differ diff --git a/utils_v2/system/__pycache__/files.cpython-310.pyc b/utils_v2/system/__pycache__/files.cpython-310.pyc index 76fd4c4..edaa3cf 100644 Binary files a/utils_v2/system/__pycache__/files.cpython-310.pyc and b/utils_v2/system/__pycache__/files.cpython-310.pyc differ