pulsar-rs
pulsar-rs copied to clipboard
the consumer's ack method should wait for the CommandAckResponse
right now it sends a message to the consumer engine's channel, and only waits for that channel to have sent the message