Python Streaming Apps with Apache Pulsar for Environment Sensors
FLiP-Py-Pi-EnviroPlus. Apache Flink, Apache Pulsar, Apache Spark, Python, Raspberry Pi, Enviro+ sensors.
Code
client = pulsar.Client('pulsar://pulsar1:6650')
producer = client.create_producer(topic='persistent://public/default/rp4enviroplus' ,schem...
timwithpulsar.hashnode.dev16 min read