search

KonstantinCodes / messenger-kafka

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

Add flush timeout ms option to KafkaTransport configuration. #8

Closed doranych closed 4 years ago

doranych commented 4 years ago

You recently updated your master to v0.3 by replacing rdkafka version. That's nice, but you forgot about proper shutdown

I decided to fix this with PR.

You have similar changes in your stable branch, but i added flush timeout as option. It makes configuration more flexible.

KonstantinCodes commented 4 years ago

@doranych Thanks a bunch!!