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

Handle large message in grpc #649

Merged
merged 62 commits into from
Dec 27, 2023
Merged

Handle large message in grpc #649

merged 62 commits into from
Dec 27, 2023

Conversation

akrambek
Copy link
Contributor

@akrambek akrambek commented Dec 19, 2023

Description

Issues found across the following bindings:

  • Both grpc client and server have an issue propagating the wrong deferred
  • Flow control bug in KafkaMerged stream setting wrong reply max causing the message to stal
  • KafkaCacheClientFetch doesn't propagate headers with data init?
  • KafkaGrpc binding doesn't propagate deferred causing data to be sent in an incomplete state
  • KafkaGrpc committing at the partition state

Fixes #648
Fixes #134

akrambek and others added 30 commits October 25, 2023 13:35
…artial data frame while computing crc32c value
jfallows
jfallows previously approved these changes Dec 27, 2023
@jfallows jfallows merged commit 0218bfc into aklivity:develop Dec 27, 2023
5 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
2 participants