> >
> > > > 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
> >
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: