kafka-php
kafka-php copied to clipboard
Add sync/async sockets differentiation for broker
When attempt to use sync producer inside async consumer with the same broker, was able to access only async socket with Broker::getConnect()
. Tried to solve this issue with this PR. There already was an issue regarding this.
Thank you in advance.
Please, review this PR. Thank you in advance.
In my case i need this fix. Can somebody review this and merge into master?