Posts

Showing posts with the label consumer

Kafka Consumer Commit Timeout

Image
Kafka Consumer Commit Timeout . The apache kafka® consumer configuration parameters are organized by order of importance, ranked from high to low. You can try to increase offsets.commit.timeout.ms (on broker side) and/or monitor the status of __consumer_offsets topic. Apache Kafka Consumer Dan Iftodi from dan.iftodi.com Result = self.__commit_log_consumer.result(timeout=0) # noqa except timeouterror: Kafka consumer stuck after timeout #2228. It is raised when calling commit(msg), looking stack trace exception is generated in safekafkahandler.cs, method commit(ienumerable offset), in this piece of code: