Senden von Daten von Python zu Apache Kafka

from kafka import KafkaProducer

# Create Kafka producer
producer = KafkaProducer(
            bootstrap_servers= ['40.68.15.154:9092']
)

data = b'{"IMU_ATTI(0):Longitude":12.1949544164,"IMU_ATTI(0):Latitude":48.5544709609,"IMU_ATTI(0):numSats":17.0,"IMU_ATTI(0):barometer:Raw":253.49582,"IMU_ATTI(0):barometer:Smooth":255.02327,"IMU_ATTI(0):accel:X":0.010682675,"IMU_ATTI(0):accel:Y":0.17155257,"IMU_ATTI(0):accel:Z":-0.9582664,"IMU_ATTI(0):accel:Composite":0.9735599,"IMU_ATTI(0):gyro:X":1.450015,"IMU_ATTI(0):gyro:Y":-5.5411973,"IMU_ATTI(0):gyro:Z":-1.3730904,"IMU_ATTI(0):gyro:Composite":5.8900585,"IMU_ATTI(0):mag:X":252.0,"IMU_ATTI(0):mag:Y":528.0,"IMU_ATTI(0):mag:Z":1693.0,"IMU_ATTI(0):mag:Mod":1791.0,"IMU_ATTI(0):velN":-1.7116269,"IMU_ATTI(0):velE":-1.4413586,"IMU_ATTI(0):velD":-0.10865045,"IMU_ATTI(0):velComposite":2.2403095,"IMU_ATTI(0):velH":2.2376731592,"IMU_ATTI(0):GPS-H":0.6064961108,"IMU_ATTI(0):roll":-10.7684243606,"IMU_ATTI(0):pitch":3.4042994237,"IMU_ATTI(0):yaw":-54.5466288079,"IMU_ATTI(0):yaw360":305.4533711921,"IMU_ATTI(0):totalGyro:Z":-866.1277259697,"IMU_ATTI(0):totalGyro:X":40.1596527467,"IMU_ATTI(0):totalGyro:Y":-294.8698078468,"IMU_ATTI(0):magYaw":-67.5831023067,"IMU_ATTI(0):distanceHP":30.800420799,"IMU_ATTI(0):distanceTravelled":427.6726274964,"IMU_ATTI(0):directionOfTravel[mag]":-142.1672631393,"IMU_ATTI(0):directionOfTravel[true]":-138.9533575863,"IMU_ATTI(0):temperature":64.92,"General:relativeHeight":6.5999999046,"GPS(0):Long":12.1949627,"GPS(0):Lat":48.554476,"GPS(0):Date":20191203.0,"GPS(0):heightMSL":395.005,"GPS(0):hDOP":65.0,"GPS(0):pDOP":119.0,"GPS(0):sAcc":889.0,"GPS(0):numGPS":9.0,"GPS(0):numGLNAS":8.0,"GPS(0):numSV":17.0,"GPS(0):velN":-1.61,"GPS(0):velE":-1.69,"GPS(0):velD":-0.09,"RC:Aileron":-10000.0,"RC:Elevator":0.0,"RC:Rudder":0.0,"RC:Throttle":0.0,"Motor:Speed:RFront":12873.0,"Motor:Speed:LFront":10978.0,"Motor:Speed:LBack":11090.0,"Motor:Speed:RBack":12501.0,"Motor:EscTemp:RFront":34.0,"Motor:EscTemp:LFront":30.0,"Motor:EscTemp:LBack":24.0,"Motor:EscTemp:RBack":29.0,"Motor:PPMrecv:RFront":1646.0,"Motor:PPMrecv:LFront":1517.0,"Motor:PPMrecv:LBack":1554.0,"Motor:PPMrecv:RBack":1645.0,"Motor:PPMsend:RFront":1648.0,"Motor:PPMsend:LFront":1517.0,"Motor:PPMsend:LBack":1548.0,"Motor:PPMsend:RBack":1636.0,"Motor:V_out:RFront":68.6,"Motor:V_out:LFront":54.3,"Motor:V_out:LBack":57.5,"Motor:V_out:RBack":68.5,"Motor:Volts:RFront":11.1,"Motor:Volts:LFront":11.2,"Motor:Volts:LBack":11.2,"Motor:Volts:RBack":11.1,"Motor:Current:RFront":1.11,"Motor:Current:LFront":0.64,"Motor:Current:LBack":0.84,"Motor:Current:RBack":1.32,"Motor:thrustAngle":-94.4967645516,"AirComp:AirSpeedBody:X":-0.7803104,"AirComp:AirSpeedBody:Y":-4.5653834,"AirComp:Alti":1.4048942,"AirComp:WindSpeed":1.194598,"AirComp:Wind:X":-1.1608922,"AirComp:Wind:Y":-0.28176853,"AirComp:MotorSpeed":239.39796,"AirComp:VelLevel":111.0,"flyCState":6.0,"MotorCtrl:PWM:RFront":66.04,"MotorCtrl:PWM:LFront":49.64,"MotorCtrl:PWM:LBack":53.5,"MotorCtrl:PWM:RBack":64.51,"droneId":0.0,"flightId":0.0}'

topic_name = "quickstart-events"
producer.send(topic_name, value=data)
producer.close()