KAFKA-16262: Add IQv2 to Kafka Streams documentation #21367
+97
−0
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
if a specific Serde is used earlier in the code, it will reuse that one instead of looking at the global defaults.
1. Added a new file config/streams.properties. 2. This file includes most of the essential configuraions with their respective defaulf values. 3. Any Developer can use this file as a base template and override the specific configuration as per their requirements.
1. Added a new file config/streams.properties. 2. This file includes most of the essential configuraions with their respective defaulf values. 3. Any Developer can use this file as a base template and override the specific configuration as per their requirement.
1. Added a new file config/streams.properties. 2. This file includes most of the essential configurations with their respective default values. 3. Any Developer can use this file as a base template and override the specific configuration as per their requirement.
1. Added a new file config/streams.properties. 2. This file includes most of the essential configurations with their respective default values. 3. Any Developer can use this file as a base template and override the specific configuration as per their requirement.
1. Added a new file config/streams.properties. 2. This file includes most of the essential configurations with their respective default values. 3. Any Developer can use this file as a base template and override the specific configuration as per their requirement.
This reverts commit 6196acf.
This reverts commit aa79e13. # Conflicts: # config/streams.properties
1. Added a new file config/streams.properties. 2. This file includes most of the essential configurations with their respective default values. 3. Any Developer can use this file as a base template and override the specific configuration as per their requirement.
This reverts commit 71473d1.
Documented Interactive Queries v2 in the Streams Interactive Queries developer guide. The update positions IQv2 as the new API, includes a basic usage example, and clearly states that the API is not yet feature complete, while keeping IQv1 documented as the legacy API.
Signed-off-by: mshijin-ksolves <[email protected]>
mjsax
changed the title
Member
|
@aliehsaeedii for review :) |
Contributor
There was a problem hiding this comment.
Thanks @mshijin-ksolves for bridging the gap. I made the first round of review.
| IQv2 improves API safety, extensibility, and error handling by: | ||
|
|
||
| - Decoupling query definition from store internals | ||
| - Returning structured query results instead of throwing exceptions |
Contributor
There was a problem hiding this comment.
Could we add returns metadata (prtitions) beside query results?
|
|
||
| ``` | ||
| // Build a query to fetch the value for a specific key | ||
| StateQueryRequest<KeyQuery<String, Long>> request = |
Contributor
There was a problem hiding this comment.
Did you run this test? It needs to be StateQueryRequest<Long>
|
|
||
| 3. **Read the Result** | ||
| ``` | ||
| if (result.hasFailures()) { |
Contributor
There was a problem hiding this comment.
StateQueryResult (result) does not provide these methods. First obtain a QueryResult object by calling one of the getPartitions... or getGlobalResult methods, and then invoke the methods on that object. Please verify this with a real example before posting the code. Thanks.
| System.out.println("Query result: " + value); | ||
| } | ||
|
|
||
| ## Comparison : Interactive Queries (IQv1) and (IQv2) |
Contributor
There was a problem hiding this comment.
nit: remove white-space before :
Could it be Comparison of IQv1 and IQv2?
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
3 participants
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Description: This change updates the documentation to introduce Interactive Queries v2 (IQv2) as a new API and improve user awareness, despite it currently being feature-incomplete.
The documentation now includes:
Please review the changes and provide feedback or suggestions for further improvements.
Ticket link:- https://issues.apache.org/jira/browse/KAFKA-16262