1234567891011121314151617 |
- #!/usr/bin/env python3
- from MessageCorps.broker import kafka_consumer
- import logging
- logging.basicConfig(level=logging.DEBUG)
- def main():
- consumer = kafka_consumer(bootstrap_servers="localhost:9092", topic="VideoStream")
- for message in consumer.consume():
- print(message)
- if __name__ == '__main__':
- main()
|