Tags: mohdAarifkartrocket/php-kafka-consumer
Tags
Improve kafka config handling (#43) Right now is not possible to customize consumer options, making it impossible for more advanced use cases that need a fine-grained control of the consumer options. Add possibility to use auto commit instead of the default manual commit. Add possibility for the user to pass custom kafka options to the consumer.
Fix internal retry rdkafka error. (#32) We made an adjustment to disregard the error RD_KAFKA_RESP_ERR__TIMED_OUT which is internal to the lib of rdkafka. This error happens because we don't have a message to be consumed and the return is null. Only that the error is registered in rdkafka, which is not necessarily an error that we must consider.
Improve error handling For committing and consuming messages there were some types of erros that could be ignored or retryed in order to avoid unnecessary crashes in the consumer clients. This commit updates the list of ignorable erros when consuming and implements the exponential backoff algorithm for retrying when committing offsets.
PreviousNext