KonstantinCodes / messenger-kafka

Simple Kafka transport for Symfony Messenger.
MIT License
84 stars 35 forks source link

Do not fail on "Local: Broker transport failure" but keep consuming #21

Closed rdotter closed 4 years ago

rdotter commented 4 years ago

When Local: Broker transport failure occures, it not results in a fatal error.

Before we used the Enqueue integration of Kafka and also added there the ignore error. https://github.com/php-enqueue/rdkafka/blob/master/RdKafkaConsumer.php This resulted in a stable good working consumer for our Enterprise Kafka environment.

@KonstantinCodes

KonstantinCodes commented 4 years ago

Thank you @rdotter