Improve the ack changes for synchronous
AkbaraliShaikh opened this issue · 0 comments
AkbaraliShaikh commented
Summary
Due to the current ack changes, connections are being disconnected as soon as the server read deadline is reached because they are unable to read the next message until the current message answer is acknowledged.
Proposed solution
The solution is to create the ack go-routine to handle the response messages for the connection
Once the message is received, it will put into the acknowledge channel, and then the response is returned once the message published to the kafka is successful.
And the next message of the current connections will not be blocked it will be keep on reading.
And there will be a single go-routine for all the ack message handling.