root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity
kafka/streams
History
leah f5a2fbac6d
KAFKA-10366 & KAFKA-9649: Implement KIP-659 to allow TimeWindowedDeserializer and TimeWindowedSerde to handle window size (#9253) 
See KIP details and discussions here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-659%3A+Improve+TimeWindowedDeserializer+and+TimeWindowedSerde+to+handle+window+size

Deprecates methods that allow users to skip setting a window size when one is needed. Adds a window size streams config to allow the timeWindowedDeserializer to calculate window end time.

Reviewers: Walker Carlson <wcarlson@confluent.io>, John Roesler <vvcephei@apache.org>, Guozhang Wang <wangguoz@gmail.com>
 		2021-02-01 16:20:35 -08:00
..
examples/src KAFKA-10366 & KAFKA-9649: Implement KIP-659 to allow TimeWindowedDeserializer and TimeWindowedSerde to handle window size (#9253) 2021-02-01 16:20:35 -08:00
quickstart
…
src KAFKA-10366 & KAFKA-9649: Implement KIP-659 to allow TimeWindowedDeserializer and TimeWindowedSerde to handle window size (#9253) 2021-02-01 16:20:35 -08:00
streams-scala KAFKA-8744: Update Scala API to give names to processors (#9738) 2021-01-28 09:57:18 -05:00
test-utils/src KAFKA-10867: Improved task idling (#9840) 2021-01-27 21:57:20 -06:00
upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests
…
upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests
…
.gitignore
…