buseynehannes opened a new pull request, #22441: URL: https://github.com/apache/kafka/pull/22441
This is a draft PR/Proof of Concept for KIP-1352. KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1352%3A+Ranges+and+Range+Aggregations+in+the+Kafka+Streams+DSL Jira: [https://issues.apache.org/jira/browse/KAFKA-12345](https://www.google.com/search?q=https://issues.apache.org/jira/browse/KAFKA-12345) Discuss Thread: (Link to your mailing list thread once it appears in the archives) Note: This PR is currently a WIP to demonstrate the RangeStoreProcessor and RangeAggregateProcessor topology split, as well as the CloseableIterator lifecycle management. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
