Lese ein Kafka Topic in Python

Um zu sehen, ob die Daten wirklich ankommen.

from kafka import KafkaConsumer
from json import loads
import json
import time

consumer = KafkaConsumer(
    'quickstart-events',
    bootstrap_servers=['40.68.15.154:9092'],
    auto_offset_reset='latest',
    enable_auto_commit=True,
    group_id='test-consumer-group'
)


for message in consumer:
    try:
         #print(message.value)
        json_data = json.loads(message.value)
        
        print(data)
        
        
    except:
        print(message.value)