Forum Archive

Using Kafka with Pythonista

ProgrammingGo

Hi,

I am using several CC2650 STK and I wanted to use kafka (producer and consumer) for data stream processing. I was trying to integrate the producer and consumer in the app, but it seems to me that I need to use threads to use Producer and Consumer simultaneously in the same app to be able to sending data to kafka and listening for answers. I was trying to separately implement them (two different apps) and it worked, but bundle them together I need to use threads. My problem is that looking at the given Sensortag example a delegate is used, so creating to classes and use threading is not working. Do you know how I can get solve the problem?

mikael

@ProgrammingGo, as far as I understand, delegates and threading are not inherently incompatible.

Is there some (as simple as possible) code you can link to?

JonB

Bluetooth in pythonista is tricky, especially with multiple devices. Since cb module doesn't expose all of the delegate input args, you often cannot tell which peripheral is calling back.