Skip to content

Tags: mohdAarifkartrocket/php-kafka-consumer

Tags

2.3.1

Toggle 2.3.1's commit message
Updates tests to the latest dependency versions

2.3.0

Toggle 2.3.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
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.

2.2.4

Toggle 2.2.4's commit message
Removes improper configs

Some producer configs were being passed to the consumer and vice versa.
Such improper configs were causing some configuration warnings. This
commit fixes the configs and removes the problem causing the warnings.

2.2.3

Toggle 2.2.3's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
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.

2.2.2

Toggle 2.2.2's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Add retry (#31)

A class has been added with all the retry logic that should be used in commit and message consumption.

Consumption starts to deal with timeout errors, retaining in the case of consumption timeout.

2.2.1

Toggle 2.2.1's commit message
Adds .gitignore so users don't pull uneeded files

2.2.0

Toggle 2.2.0's commit message
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.

1.4.4

Toggle 1.4.4's commit message
Improve log message

1.4.3

Toggle 1.4.3's commit message
Fix log of commit exception

1.4.2

Toggle 1.4.2's commit message
Add --maxMessage input