Re: Heartbeats while consuming a message in kafka-python

2017-02-22 Thread Martin Sucha
> > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > > > > 62%3A+Allow+consumer+to+send+heartbeats+from+a+background+thread > > > > > > > > As for python client, as far as I know this background thread > approach > >

Heartbeats while consuming a message in kafka-python

2017-02-21 Thread Martin Sucha
Hello, I'm processing messages using kafka-python from a single topic, but ocassionally I have a message that might take a while to process, so I'd like to send heartbeats while processing the message. My program works something like this: consumer = KafkaConsumer(...) for message in consumer: