[GitHub] kafka pull request #4334: [KAFKA-6265] GlobalKTable missing #queryableStoreN...

[ConcurrencyPractitioner]

Github user ConcurrencyPractitioner closed the pull request at:

https://github.com/apache/kafka/pull/4334


---

[GitHub] kafka pull request #4340: [KAFKA-6265] GlobalKTable missing #queryableStoreN...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner opened a pull request:

https://github.com/apache/kafka/pull/4340

[KAFKA-6265] GlobalKTable missing #queryableStoreName()



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka kafka-6265

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/4340.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 #4340


commit bc50a83789ab3f1ad13b4db74ef02a3a3368eef0
Author: RichardYuSTUG <yohan.richard@gmail.com>
Date:   2017-12-18T22:12:52Z

[KAFKA-6265] GlobalKTable missing #queryableStoreName()




---

[GitHub] kafka pull request #4339: [KAFKA-6328] Exclude node groups belonging to glob...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner opened a pull request:

https://github.com/apache/kafka/pull/4339

[KAFKA-6328] Exclude node groups belonging to global stores in 
InternalTopologyBuilder#makeNodeGroups



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka kafka-6238

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/4339.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 #4339


commit ab7531552c9e830ad87f06132f45b3257a3632fa
Author: RichardYuSTUG <yohan.richard@gmail.com>
Date:   2017-12-18T22:01:02Z

[KAFKA-6328] Exclude node groups belonging to global stores in 
InternalTopologyBuilder

commit 42ea1f0e885eda70b60712ded801ba010a9a2c7e
Author: RichardYuSTUG <yohan.richard@gmail.com>
Date:   2017-12-18T22:07:58Z

Testing

commit da2bf85318db465b325383ecded9b51474f1d35b
Author: RichardYuSTUG <yohan.richard@gmail.com>
Date:   2017-12-18T22:09:10Z

[KAFKA-6328] Exclude node groups belonging to global stores in 
InternalTopologyBuilder#makeNodeGroups




---

[GitHub] kafka pull request #4334: [KAFKA-6265] GlobalKTable missing #queryableStoreN...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner opened a pull request:

https://github.com/apache/kafka/pull/4334

[KAFKA-6265] GlobalKTable missing #queryableStoreName()




You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/4334.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 #4334


commit 9264592828fe7bc38c660588c07526de17a5b761
Author: RichardYuSTUG <yohan.richard@gmail.com>
Date:   2017-12-15T23:40:54Z

[KAFKA-6265] GlobalKTable missing #queryableStoreName()




---

[GitHub] kafka pull request #4258: [KAFKA-4499] Add all() and fetchAll() API for quer...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner opened a pull request:

https://github.com/apache/kafka/pull/4258

[KAFKA-4499] Add all() and fetchAll() API for querying

*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*

*Summary of testing strategy (including rationale)
for the feature or bug fix. Unit and/or integration
tests are expected for any behaviour change and
system tests should be considered for larger changes.*

### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation 
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)


You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/4258.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 #4258


commit 0dfd5a62395705d11ed73ed382aa0d3247c6da7c
Author: RichardYuSTUG <yohan.richard@gmail.com>
Date:   2017-11-23T04:18:38Z

[KAFKA-4499] Add all() and fetchAll() API for querying




---

[GitHub] kafka pull request #4162: [KAFKA-4499] Add "getAllKeys" for querying windowe...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner opened a pull request:

https://github.com/apache/kafka/pull/4162

[KAFKA-4499]  Add "getAllKeys" for querying windowed KTable stores 



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/4162.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 #4162


commit 5635d189bb1f0a71f831a44626c206f2360c2f5e
Author: RichardYuSTUG <yohan.richard@gmail.com>
Date:   2017-10-30T22:07:27Z

[KAFKA-4499] KafkaKAFKA-4499




---

[GitHub] kafka pull request #4110: [KAFKA-5212] Consumer ListOffsets request can star...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner opened a pull request:

https://github.com/apache/kafka/pull/4110

[KAFKA-5212] Consumer ListOffsets request can starve group heartbeats



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/4110.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 #4110


commit 9bdb5d36c3b2c15559f663aeab863b994878cc1d
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-10-21T18:38:44Z

Rebased version of tests




---

[GitHub] kafka pull request #4049: [KAFKA-5212] Consumer ListOffsets request can star...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner opened a pull request:

https://github.com/apache/kafka/pull/4049

[KAFKA-5212] Consumer ListOffsets request can starve group heartbeats

Through the identification of the poll method in ConsumerCoordinator as the 
place where the heartbeat is sent, I modified the metadata so that it polled 
periodically every interval for a heartbeat.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/4049.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 #4049


commit 431bc8011ce3f8aaa677e2f6743c9b069a1eec8c
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-10-10T03:45:23Z

[KAFKA-5212] Consumer ListOffsets request can starve group heartbeats




---

[GitHub] kafka pull request #3916: KAFKA-5765 Move merge() from StreamsBuilder to KSt...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner opened a pull request:

https://github.com/apache/kafka/pull/3916

KAFKA-5765 Move merge() from StreamsBuilder to KStream



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/3916.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 #3916


commit 709e850de935887881379c1dd3ed4701895c55a7
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-09-20T03:12:44Z

KAFKA-5765 Polished version of merge




---

[GitHub] kafka pull request #3880: KAFKA-5765 Move merge() from StreamsBuilder to KSt...

[ConcurrencyPractitioner]

Github user ConcurrencyPractitioner closed the pull request at:

https://github.com/apache/kafka/pull/3880


---

[GitHub] kafka pull request #3880: KAFKA-5765 Move merge() from StreamsBuilder to KSt...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner reopened a pull request:

https://github.com/apache/kafka/pull/3880

KAFKA-5765 Move merge() from StreamsBuilder to KStream

I have defined a {{merge()}} method to KStream. 
KStreamImpl overrides the {{merge()}} method.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/3880.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 #3880


commit 572f5bfa5a0e334c5b75a6e3353aa6f4b5b95f39
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-09-16T23:38:53Z

KAFKA-5765 diff --git 
a/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java 
b/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java

commit 71ac422ceb86e5c1d368a714b0af743eb2ad62eb
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-09-16T23:54:10Z

KAFKA-5765 Move merge() from StreamsBuilder to KStream




---

[GitHub] kafka pull request #3880: KAFKA-5765 Move merge() from StreamsBuilder to KSt...

[ConcurrencyPractitioner]

Github user ConcurrencyPractitioner closed the pull request at:

https://github.com/apache/kafka/pull/3880


---

[GitHub] kafka pull request #3880: KAFKA-5765 Move merge() from StreamsBuilder to KSt...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner reopened a pull request:

https://github.com/apache/kafka/pull/3880

KAFKA-5765 Move merge() from StreamsBuilder to KStream

I have defined a {{merge()}} method to KStream. 
KStreamImpl overrides the {{merge()}} method.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/3880.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 #3880


commit 572f5bfa5a0e334c5b75a6e3353aa6f4b5b95f39
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-09-16T23:38:53Z

KAFKA-5765 diff --git 
a/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java 
b/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java

commit 71ac422ceb86e5c1d368a714b0af743eb2ad62eb
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-09-16T23:54:10Z

KAFKA-5765 Move merge() from StreamsBuilder to KStream




---

[GitHub] kafka pull request #3880: KAFKA-5765 Move merge() from StreamsBuilder to KSt...

[ConcurrencyPractitioner]

Github user ConcurrencyPractitioner closed the pull request at:

https://github.com/apache/kafka/pull/3880


---

[GitHub] kafka pull request #3880: KAFKA-5765 Move merge() from StreamsBuilder to KSt...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner opened a pull request:

https://github.com/apache/kafka/pull/3880

KAFKA-5765 Move merge() from StreamsBuilder to KStream

I have defined a {{merge()}} method to KStream. 
KStreamImpl overrides the {{merge()}} method.

You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/3880.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 #3880


commit 572f5bfa5a0e334c5b75a6e3353aa6f4b5b95f39
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-09-16T23:38:53Z

KAFKA-5765 diff --git 
a/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java 
b/streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java




---

[GitHub] kafka pull request #3842: KAFKA-5301 Improve exception handling on consumer ...

[ConcurrencyPractitioner]

Github user ConcurrencyPractitioner closed the pull request at:

https://github.com/apache/kafka/pull/3842


---

[GitHub] kafka pull request #3842: KAFKA-5301 Improve exception handling on consumer ...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner reopened a pull request:

https://github.com/apache/kafka/pull/3842

KAFKA-5301 Improve exception handling on consumer path

This is an improvised approach towards fixing @guozhangwang 's second 
issue. 
I have changed the method return type as well as override such that it 
returns exception.
If the exception returned is not null (the default value), than we skip the 
callback.


You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/3842.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 #3842


commit 6290df2070f215d0b355f3e59717d911e50b8973
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-09-13T03:19:24Z

[Kafka-5301] Improve exception handling on consumer path

commit 3a01de2d4e293d15da5c390bc5179243bbdb833e
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-09-13T22:34:11Z

Exception handling add-on




---

[GitHub] kafka pull request #3842: KAFKA-5301 Improve exception handling on consumer ...

[ConcurrencyPractitioner]

Github user ConcurrencyPractitioner closed the pull request at:

https://github.com/apache/kafka/pull/3842


---

[GitHub] kafka pull request #3842: [Kafka-5301] Improve exception handling on consume...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner opened a pull request:

https://github.com/apache/kafka/pull/3842

[Kafka-5301] Improve exception handling on consumer path

This is an improvised approach towards fixing @guozhangwang 's second 
issue. 
I have changed the method return type as well as override such that it 
returns exception.
If the exception returned is not null (the default value), than we skip the 
callback.


You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/3842.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 #3842


commit 6290df2070f215d0b355f3e59717d911e50b8973
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-09-13T03:19:24Z

[Kafka-5301] Improve exception handling on consumer path




---

[GitHub] kafka pull request #3745: [KAFKA-4468] Correctly calculate the window end ti...

[ConcurrencyPractitioner]

GitHub user ConcurrencyPractitioner opened a pull request:

https://github.com/apache/kafka/pull/3745

[KAFKA-4468] Correctly calculate the window end timestamp after read from 
state stores

I have decided to use the following approach to fixing this bug:

1) Since the Window Size in WindowedDeserializer was originally unknown, I 
have initialized
a field _windowSize_ and created a constructor to allow it to be 
instantiated

2) The default size for __windowSize__ is _Long.MAX_VALUE_. If that is the 
case, then the 
deserialize method will return an Unlimited Window, or else will return 
Timed one.

3) Temperature Demo was modified to demonstrate how to use this new 
constructor, given
that the window size is known.


You can merge this pull request into a Git repository by running:

$ git pull https://github.com/ConcurrencyPractitioner/kafka trunk

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/kafka/pull/3745.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 #3745


commit 7dcf42e110dadd3f257c7ea1a0d10adc60bd0eea
Author: Richard Yu <richar...@richards-air.attlocal.net>
Date:   2017-08-26T20:18:48Z

KAFKA-4468 Correctly calculate the window end timestamp after read from 
state stores




---
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.
---