-
Notifications
You must be signed in to change notification settings - Fork 1k
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
chore: passing consistency token using request properties in HARouting #8312
chore: passing consistency token using request properties in HARouting #8312
Conversation
ksqldb-engine/src/main/java/io/confluent/ksql/physical/pull/HARouting.java
Outdated
Show resolved
Hide resolved
fe817c8
to
20c2d2f
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks, @patrickstuedi !
Just one thing to add on top of @vpapavas 's comment.
ksqldb-engine/src/main/java/io/confluent/ksql/physical/pull/HARouting.java
Outdated
Show resolved
Hide resolved
ksqldb-engine/src/main/java/io/confluent/ksql/physical/pull/HARouting.java
Outdated
Show resolved
Hide resolved
baef55b
to
36b72a9
Compare
...app/src/test/java/io/confluent/ksql/rest/integration/PullQueryConsistencyFunctionalTest.java
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, mod @vpapavas 's open question.
...app/src/test/java/io/confluent/ksql/rest/integration/PullQueryConsistencyFunctionalTest.java
Outdated
Show resolved
Hide resolved
...app/src/test/java/io/confluent/ksql/rest/integration/PullQueryConsistencyFunctionalTest.java
Show resolved
Hide resolved
e605095
to
a857c86
Compare
...app/src/test/java/io/confluent/ksql/rest/integration/PullQueryConsistencyFunctionalTest.java
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you @patrickstuedi ! LGTM just add the check in the test that the CV is actually correct
7bbcce1
to
2f8c9f3
Compare
2f8c9f3
to
5315afb
Compare
Following the practice introduced in #8264 this PR is using request properties to pass the consistency token between servers