Catch Local: Broker transport failure and continue consuming

[rdotter]

Catch the Kafka Local: Broker transport failure (error -195) error when consuming, this happens sometimes when consuming messages. When we restart the consumer everything is just OK.

Settings for connection with Kafka:

enqueue:
    kafka:
        transport:
            global:
                group.id: XXX
                metadata.broker.list: XXX
                enable.auto.offset.store: 'false'
                socket.keepalive.enable: 'true'

@makasim

[makasim]

Thanks for your pull request! We love contributions.

However, this repository is what we call a "subtree split": a read-only copy of one directory of the main enqueue-dev repository. It is used by Composer to allow developers to depend on specific Enqueue package.

If you want to contribute, you should instead open a pull request on the main repository:

https://github.com/php-enqueue/enqueue-dev

Read the contribution guide

https://github.com/php-enqueue/enqueue-dev/blob/master/docs/contribution.md

Thank you for your contribution!

[rdotter]

Thanks! Will create a MR via this contribution guide :-)