We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
Kafka binding internally uses progress offset to represent where the client should recover from after receiving a DATA frame.
DATA
However, this is then inconsistent with FLUSH frame which represents current position in the stream.
FLUSH
Review the use of partitionOffset vs progressOffset, also BEGIN partitionOffset vs DATA partitionOffset to determine if this can be further simplified.
partitionOffset
progressOffset
BEGIN
The text was updated successfully, but these errors were encountered:
jfallows
No branches or pull requests
Kafka binding internally uses progress offset to represent where the client should recover from after receiving a
DATA
frame.However, this is then inconsistent with
FLUSH
frame which represents current position in the stream.Review the use of
partitionOffset
vsprogressOffset
, alsoBEGIN
partitionOffset
vsDATA
partitionOffset
to determine if this can be further simplified.The text was updated successfully, but these errors were encountered: