output.txt

vagrant_kafka_1
vagrant_zookeeper_1
cassandra
Data stream open. Records sent:
{'id': 73531, 'name': 'Tsirmpas Dimitris', 'song': 'Summer Love', 'time': '2024-02-29 02:05'}
{'id': 63708, 'name': 'Julie Dunn', 'song': 'Faz um Vuk Vuk (Teto Espelhado)', 'time': '2024-02-29 02:05'}
{'id': 14521, 'name': 'Anna Lawson', 'song': 'Люди', 'time': '2024-02-29 02:06'}
{'id': 36957, 'name': 'Gordon Abbott', 'song': 'Elevated', 'time': '2024-02-29 02:06'}
^CTraceback (most recent call last):
  File "src/data-producer.py", line 76, in <module>
    result = loop.run_until_complete(produce())
  File "/usr/lib/python3.6/asyncio/base_events.py", line 471, in run_until_complete
    self.run_forever()
  File "/usr/lib/python3.6/asyncio/base_events.py", line 438, in run_forever
    self._run_once()
  File "/usr/lib/python3.6/asyncio/base_events.py", line 1451, in _run_once
    handle._run()
  File "/usr/lib/python3.6/asyncio/events.py", line 145, in _run
    self._callback(*self._args)
  File "src/data-producer.py", line 70, in produce
    time.sleep(INTERVAL_SECS)
KeyboardInterrupt