Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Support compressed batches in kafka client #10117

Conversation

michael-redpanda
Copy link
Contributor

@michael-redpanda michael-redpanda commented Apr 14, 2023

Fixes #3062
Fixes #8546

Pandaproxy can how handle compressed batches and return them upon consumption. Schema registry also can now
consume compressed batches saved to the _schemas topic.

Backports Required

  • none - not a bug fix
  • none - this is a backport
  • none - issue does not exist in previous branches
  • none - papercut/not impactful enough to backport
  • v23.1.x
  • v22.3.x
  • v22.2.x

Release Notes

Bug Fixes

  • Pandaproxy will no longer assert if attempting to consume compressed message batches
  • Schema Registry will no longer assert if the _schemas topic contains compressed batches

@michael-redpanda michael-redpanda force-pushed the support-compressed-batches-in-kafka-client branch from a0b36eb to 03e3616 Compare April 17, 2023 18:12
Copy link
Member

@BenPope BenPope left a comment

Choose a reason for hiding this comment

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

Very nice

src/v/storage/parser_utils.cc Outdated Show resolved Hide resolved
src/v/storage/parser_utils.cc Show resolved Hide resolved
Added calls that will decompress record_batch's synchronously
Added calls that will decompress record_batch's synchronously when
fetched via kafka client.
@michael-redpanda michael-redpanda force-pushed the support-compressed-batches-in-kafka-client branch from 03e3616 to 8bc0c58 Compare April 18, 2023 12:48
BenPope
BenPope previously approved these changes Apr 18, 2023
Added two tests, one for direct partition fetch and an additional one
that will use consumer groups.

Signed-off-by: Michael Boquard <[email protected]>
@michael-redpanda michael-redpanda added area/pandaproxy REST interface for Kafka API area/schema-registry Schema Registry service within Redpanda labels Apr 18, 2023
@michael-redpanda michael-redpanda force-pushed the support-compressed-batches-in-kafka-client branch from c1dc4c7 to 641c437 Compare April 18, 2023 14:50
@michael-redpanda
Copy link
Contributor Author

michael-redpanda commented Apr 18, 2023

@dotnwat dotnwat merged commit ffc6f94 into redpanda-data:dev Apr 18, 2023
@michael-redpanda
Copy link
Contributor Author

/backport v23.1.x

@michael-redpanda
Copy link
Contributor Author

/backport v22.3.x

@michael-redpanda
Copy link
Contributor Author

/backport v22.2.x

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area/pandaproxy REST interface for Kafka API area/redpanda area/schema-registry Schema Registry service within Redpanda
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Schema registry crashes due to compressed batches kafka/client: Support compressed batches
3 participants