def main(): consumer = kafka_consumer(bootstrap_servers="localhost:9092", topic="VideoStream") for message in consumer.consume(): print(message) if __name__ == '__main__': main()
