(20241212) Added tests to check if everything is up and running.

2024-12-12 11:53:02 +05:30
parent d7e98a4027
commit fe676ab599
9 changed files with 1 additions and 1 deletions
@@ -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()])