Skip to content

Conversation

@czirker
Copy link
Contributor

@czirker czirker commented Feb 16, 2023

Should not be merged until the bus portion has be released. Otherwise it will send events that can't be processed in firehose

jgrantr
jgrantr previously approved these changes Feb 16, 2023
firehose.putRecordBatch({
Records: [{
Data: records.join('')
Data: opts.gzipFirehose ? (records.map(r => r.toString("base64")).join('\n') + '\n') : records.join('')
Copy link
Contributor

Choose a reason for hiding this comment

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

@czirker Are we expecting the person using this to be gzipping the content themselves?

snapshot: opts.snapshot
}, opts.chunk || {});
chunkOpts.gzip = !opts.firehose;
chunkOpts.gzip = opts.gzipFirehose || !opts.firehose;
Copy link
Contributor

Choose a reason for hiding this comment

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

@czirker Or is that what this does? The chunker does the gzipping?

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Correct. The chunker will do the zipping. The user just needs to specify that they want to enable the feature using gzipFirehose:true

@jgrantr jgrantr self-requested a review February 16, 2023 17:45
jgrantr
jgrantr previously approved these changes Jan 9, 2024
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