I subscribe to topics and receive input in my main thread (this
happens to be in Python):

    consumer = kafka.KafkaConsumer(...)
    for data in consumer:
        do_stuff(data)

do_stuff(...) can hand messages off to a separate thread for
processing. Is it okay to call commit() from that thread or do I need
to do the complete lock dance for that as well?

Thanks,

Skip Montanaro

Reply via email to