GitHub user enothereska opened a pull request:
https://github.com/apache/kafka/pull/2728
KAFKA 3514: alternate calculation for min timestamp [WiP]
This alternate calculation reduces the amount of buffering kept and is
optimised for cases when out of order records are rare.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/enothereska/kafka
KAFKA-3514-stream-timestamp-min
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/2728.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2728
----
commit 1d1f7f79f396812c51515de50c18087d120eb092
Author: Eno Thereska <eno.there...@gmail.com>
Date: 2017-03-02T10:43:47Z
Initial poc
commit 1fcb484d5a294bbf289dca0735aaaccff93114ca
Author: Eno Thereska <eno.there...@gmail.com>
Date: 2017-03-02T14:48:58Z
Checkpoint test code
commit 28eb75185546f55555947beda176c3e339ec9311
Author: Eno Thereska <eno.there...@gmail.com>
Date: 2017-03-05T08:55:15Z
Checkpoint
commit 4c68bf1f90fcb583c5e63e8ac130d6a377238052
Author: Eno Thereska <eno.there...@gmail.com>
Date: 2017-03-23T15:55:21Z
Merged with trunk
commit 75022449e2e4a1ac562504c63fe292c4d5586521
Author: Eno Thereska <eno.there...@gmail.com>
Date: 2017-03-23T16:02:15Z
Cleanup
commit 28297c56e5db02b7d34d6706d31d65e38f4b19b3
Author: Eno Thereska <eno.there...@gmail.com>
Date: 2017-03-23T16:03:40Z
Cleanup
commit 863e4e60b26ba7a718157863dc73a83779decb08
Author: Eno Thereska <eno.there...@gmail.com>
Date: 2017-03-23T16:40:49Z
Adjusted tests
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
