13 lines
280 B
Python
13 lines
280 B
Python
|
from kafka import KafkaConsumer
|
||
|
|
import json
|
||
|
|
|
||
|
|
consumer = KafkaConsumer(
|
||
|
|
'test-lakehouse',
|
||
|
|
bootstrap_servers=['10.0.21.36:9092'],
|
||
|
|
auto_offset_reset='latest'
|
||
|
|
)
|
||
|
|
|
||
|
|
print("Waiting for new messages...")
|
||
|
|
for msg in consumer:
|
||
|
|
print(f"Received: {msg.value.decode('utf-8')}")
|