Skip to content

Implemented decompression on consumer side#98

Merged
merlimat merged 2 commits intoapache:masterfrom
merlimat:fixed-acks
Nov 14, 2019
Merged

Implemented decompression on consumer side#98
merlimat merged 2 commits intoapache:masterfrom
merlimat:fixed-acks

Conversation

@merlimat
Copy link
Contributor

Motivation

Implemented the batch decompression on the consumer side

return err
}

uncompressedHeadersAndPayload, err := pc.Decompress(msgMeta, headersAndPayload)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

is there a way to implement this logic in the message reader?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Main reason to have this outside is to handle the proper "decompress error" without the need to check the error types.

@merlimat merlimat merged commit ccd4547 into apache:master Nov 14, 2019
@wolfstudy wolfstudy added this to the 0.1.0 milestone Dec 17, 2019
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants