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