[GitHub] kafka pull request #4309: KAFKA-4218: Enable access to key in ValueTransform...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/4309 KAFKA-4218: Enable access to key in ValueTransformer and ValueMapper This PR is the partial implementation for KIP-149. As the discussion for this KIP is still ongoing, I made a PR on the "safe" portions of the KIP (so that it can be included in the next release) which are 1) `ValueMapperWithKey`, 2) `ValueTransformerWithKeySupplier`, and 3) `ValueTransformerWithKey`. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KIP-149_hope_last Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/4309.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 #4309 commit 91c1108c72f2f3b3097dcff3bd2aad237789215e Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-12-09T00:56:36Z Submit the first version of KIP-149 ---
[GitHub] kafka pull request #3570: KAFKA-4218: KIP-149, Enabling withKey interfaces i...
Github user jeyhunkarimov closed the pull request at: https://github.com/apache/kafka/pull/3570 ---
[GitHub] kafka pull request #4149: KAFKA-6126: Reduce rebalance time by not checking ...
Github user jeyhunkarimov closed the pull request at: https://github.com/apache/kafka/pull/4149 ---
[GitHub] kafka pull request #4149: KAFKA-6126: Reduce rebalance time by not checking ...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/4149 KAFKA-6126: Reduce rebalance time by not checking if created topics are available You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-6126 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/4149.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 #4149 commit 94ba5ebae44b73b6a73fdb85ed6a9d527923c0d7 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-10-27T23:18:49Z Reduce rebalance time by not checking if created topics are available ---
[GitHub] kafka pull request #3601: KAFKA-4218: Add withkey methods to KGroupedTable
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3601 KAFKA-4218: Add withkey methods to KGroupedTable This PR aims to add withKey methods to KGroupedTable interface. This PR is part of [KIP-149](https://cwiki.apache.org/confluence/display/KAFKA/KIP-149%3A+Enabling+key+access+in+ValueTransformer%2C+ValueMapper%2C+and+ValueJoiner). I separated the complete PR into 4 parts as discussed in [here](https://github.com/apache/kafka/pull/3570#issuecomment-317645747). So, this PR concentrates on adding withKey methods to KGroupedTable interface. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KIP-149_KGroupedTable Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3601.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 #3601 commit 00f10288fac503764c8c6af8ae1907864d042dae Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-07-28T23:25:59Z Add withkey interfaces Add withkey interfaces Add withKey converters in AbstractStream Add withKey interface to KGroupedTable Remove unnecessary lines Remove unnecessary lines --- 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. ---
[GitHub] kafka pull request #3600: KAFKA-4218 : Add withkey methods to KTable
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3600 KAFKA-4218 : Add withkey methods to KTable This PR aims to add withKey methods to KTable interface. This PR is part of [KIP-149](https://cwiki.apache.org/confluence/display/KAFKA/KIP-149%3A+Enabling+key+access+in+ValueTransformer%2C+ValueMapper%2C+and+ValueJoiner). I separated the complete PR into 4 parts as discussed in [here](https://github.com/apache/kafka/pull/3570#issuecomment-317645747). So, this PR concentrates on adding withKey methods to KTable interface. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KIP-149_KTable Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3600.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 #3600 commit 8e34c603d2db4a71127972cfd2c2efa35b32cc6a Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-07-28T23:25:59Z Add withkey interfaces Add withkey interfaces Add withKey converters in AbstractStream Add withKey interfaces to KTable Remove unnecessary lines --- 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. ---
[GitHub] kafka pull request #3599: KAFKA-4218: Add withkey methods to KGroupedStream
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3599 KAFKA-4218: Add withkey methods to KGroupedStream This PR aims to add withKey methods to KGroupedStream interface. This PR is part of [KIP-149](https://cwiki.apache.org/confluence/display/KAFKA/KIP-149%3A+Enabling+key+access+in+ValueTransformer%2C+ValueMapper%2C+and+ValueJoiner). I separated the complete PR into 4 parts as discussed in [here](https://github.com/apache/kafka/pull/3570#issuecomment-317645747). So, this PR concentrates on adding withKey methods to KGroupedStream interface. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KIP-149_KGroupedStream Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3599.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 #3599 commit 6af52ab0822a9c557fbfd45a67d6584b506287ad Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-07-28T23:25:59Z Add withkey interfaces Add withkey interfaces Add withKey converters in AbstractStream Add tests Remove unnecessary changes --- 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. ---
[GitHub] kafka pull request #3598: KAFKA-4218: Add withkey methods to KStream
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3598 KAFKA-4218: Add withkey methods to KStream This PR aims to add withKey methods to KStream interface. This PR is part of [KIP-149](https://cwiki.apache.org/confluence/display/KAFKA/KIP-149%3A+Enabling+key+access+in+ValueTransformer%2C+ValueMapper%2C+and+ValueJoiner). I separated the complete PR into 4 parts as discussed in [here](https://github.com/apache/kafka/pull/3570#issuecomment-317645747). So, this PR concentrates on adding withKey methods to KStream interface. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KIP-149_KStream Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3598.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 #3598 commit c37be59024ea7fd69e1a8ffe2bae1272c3035aec Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-07-28T23:25:59Z Add withkey interfaces Add withkey interfaces Add withKey converters in AbstractStream Add KStream withKey interfaces Remove unnecessary lines --- 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. ---
[GitHub] kafka pull request #2946: KAFKA-4218: Enable access to key in ValueTransform...
Github user jeyhunkarimov closed the pull request at: https://github.com/apache/kafka/pull/2946 --- 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. ---
[GitHub] kafka pull request #3570: KAFKA-4218: KIP-149, Enabling withKey interfaces i...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3570 KAFKA-4218: KIP-149, Enabling withKey interfaces in streams This PR aims to provide key access to ValueMapper, ValueJoiner, ValueTransformer, Initializer and Reducer interfaces. More details can be found in [here](https://cwiki.apache.org/confluence/display/KAFKA/KIP-149%3A+Enabling+key+access+in+ValueTransformer%2C+ValueMapper%2C+and+ValueJoiner) You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KIP-149 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3570.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 #3570 commit a1bbfdca86c53359ef75217ec4aaad06179d967d Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-07-21T23:18:05Z Add withKey methods to KStream, KGroupedStream, KTable and KGroupedTable interfaces --- 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. ---
[GitHub] kafka pull request #3294: KAFKA-4653: Improve test coverage of RocksDBStore
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3294 KAFKA-4653: Improve test coverage of RocksDBStore You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4653 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3294.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 #3294 commit 77e65eaa07855651cf4449de2cca074a9fe05ece Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-06-10T17:54:27Z RocksDBStore putAll covered --- 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. ---
[GitHub] kafka pull request #3293: KAFKA-4658: Improve test coverage InMemoryKeyValue...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3293 KAFKA-4658: Improve test coverage InMemoryKeyValueLoggedStore You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4658 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3293.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 #3293 commit f5e5e8af539d8ce0e27232d8b9aac725ec19f80c Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-06-10T16:23:54Z InMemoryKeyValueLoggedStore tests improved with putAll() and persistent() --- 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. ---
[GitHub] kafka pull request #3292: KAFKA-4656: Improve test coverage of CompositeRead...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3292 KAFKA-4656: Improve test coverage of CompositeReadOnlyKeyValueStore You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4656 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3292.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 #3292 commit 3fa739bf25c0a92e405635d9c0ae7f9c90ca8027 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-06-10T15:28:55Z Exceptions not covered in CompositeReadOnlyKeyValueStoreTest Exceptions not covered in CompositeReadOnlyKeyValueStoreTest Exceptions not covered in CompositeReadOnlyKeyValueStoreTest --- 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. ---
[GitHub] kafka pull request #3291: KAFKA-4659: Improve test coverage of CachingKeyVal...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3291 KAFKA-4659: Improve test coverage of CachingKeyValueStore You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4659 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3291.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 #3291 commit c640cdc430c287e100cbb94a6956005c029e83e5 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-06-10T13:22:51Z putIfAbsent and null pointer exception test cases covered --- 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. ---
[GitHub] kafka pull request #3290: KAFKA-4655: Improve test coverage of CompositeRead...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3290 KAFKA-4655: Improve test coverage of CompositeReadOnlySessionStore You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4655 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3290.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 #3290 commit 0627b6b932bde199f26ffead651ce5e1d7f0ea82 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-06-10T12:13:26Z Improved coverage with exceptions in fetch and internal iterator --- 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. ---
[GitHub] kafka pull request #3288: KAFKA-4661: Improve test coverage UsePreviousTimeO...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3288 KAFKA-4661: Improve test coverage UsePreviousTimeOnInvalidTimestamp You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4661 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3288.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 #3288 commit 2f407df88b1eeb9c91df235cd3dc07b4e6cdf3ed Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-06-10T00:55:23Z Exception branch tested on UsePreviousTimeOnInvalidTimestamp --- 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. ---
[GitHub] kafka pull request #3109: KAFKA-4144: Allow per stream/table timestamp extra...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3109 KAFKA-4144: Allow per stream/table timestamp extractor A follow up RP to fix [issue](https://github.com/confluentinc/examples/commit/2cd0b87bc8a7eab0e7199fa0079db6417f0e6b63#commitcomment-22200864) You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4144-follow-up Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3109.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 #3109 commit a35b23a19358d7c2df421e290e5918a45c9cc617 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-05-20T09:26:49Z Follow up overload needed for globalTable() --- 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. ---
[GitHub] kafka pull request #3106: KAFKA-4785: Records from internal repartitioning t...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3106 KAFKA-4785: Records from internal repartitioning topics should always use RecordMetadataTimestampExtractor You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4785 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3106.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 #3106 commit 98278baae63638efc2b750b1d3f12e936d845f18 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-05-19T21:39:50Z Records from internal repartitioning topics should always use RecordMetadataTimestampExtractor --- 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. ---
[GitHub] kafka pull request #3047: KAFKA-5228: Revisit Streams DSL JavaDocs
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/3047 KAFKA-5228: Revisit Streams DSL JavaDocs You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-5228 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3047.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 #3047 commit c1ec019b40eba36d659f2bb6261a106340805b6f Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-05-13T23:40:37Z More clarification added to JavaDocs --- 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. ---
[GitHub] kafka pull request #2946: KAFKA-4218: Enable access to key in ValueTransform...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/2946 KAFKA-4218: Enable access to key in ValueTransformer This PR groups KAFKA-4218, KAFKA-4726 and KAFKA-3745. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4218 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2946.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 #2946 commit f535f8ea126a34e2854ed45e9131324099c7aa71 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-04-30T16:11:57Z KAFKA-4218 bug fix in KTableImplTest --- 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. ---
[GitHub] kafka pull request #2466: KAFKA-4144: Allow per stream/table timestamp extra...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/2466 KAFKA-4144: Allow per stream/table timestamp extractor You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4144 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2466.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 #2466 commit 2ab3b8d446938903c2447b74b29ecc2e93ee6d3a Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-01-30T12:02:26Z initial changes to classes Allow per stream/table timestamp extractor --- 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. ---
[GitHub] kafka pull request #2420: KAFKA-4613: Treat null-key records the same way fo...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/2420 KAFKA-4613: Treat null-key records the same way for joins and aggreations You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4613 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2420.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 #2420 commit 70c23d0d77d9a3e863d6a16cce632fe23ced1a6c Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-01-22T16:35:54Z KAFKA-4613: Treat null-key records the same way for joins and aggreations --- 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. ---
[GitHub] kafka pull request #2417: KAFKA-3835: Streams is creating two ProducerRecord...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/2417 KAFKA-3835: Streams is creating two ProducerRecords for each send via RecordCollector You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-3835 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2417.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 #2417 commit d803e032e3e91da88332f2f4ce257efb905ec101 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2017-01-22T01:27:11Z RecordCollector send method arguments changed --- 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. ---
[GitHub] kafka pull request #1591: KAFKA-3836: KStreamReduce and KTableReduce should ...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/1591 KAFKA-3836: KStreamReduce and KTableReduce should not pass nulls to Deserializers Minor changes to check null changes. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-3836 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1591.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 #1591 commit ac421c30f698153a5733ffb71e677633d1edbe9c Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2016-07-06T09:05:13Z KAFKA-3836 null checks v2 --- 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. ---
[GitHub] kafka pull request #1569: Kafka 3836: KStreamReduce and KTableReduce should ...
Github user jeyhunkarimov closed the pull request at: https://github.com/apache/kafka/pull/1569 --- 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. ---
[GitHub] kafka pull request #1585: KAFKA-3836: KStreamReduce and KTableReduce should ...
Github user jeyhunkarimov closed the pull request at: https://github.com/apache/kafka/pull/1585 --- 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. ---
[GitHub] kafka pull request #1586: Kafka-3836: KStreamReduce and KTableReduce should ...
Github user jeyhunkarimov closed the pull request at: https://github.com/apache/kafka/pull/1586 --- 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. ---
[GitHub] kafka pull request #1588: KAFKA-3825: Allow users to specify different types...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/1588 KAFKA-3825: Allow users to specify different types of state stores in Streams DSL You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-3825 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1588.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 #1588 commit ea2897ec26afd84772a96d447fcbe951f140e095 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2016-07-05T12:37:05Z KAFKA-3825 --- 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. ---
[GitHub] kafka pull request #1586: Kafka 3836: KStreamReduce and KTableReduce should ...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/1586 Kafka 3836: KStreamReduce and KTableReduce should not pass nulls to Deserializers You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka trunk Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1586.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 #1586 commit b12fe5aa3910577cfda2be79fbe7271dd2922bf6 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2016-07-05T09:11:38Z KAFKA-3836 updated commit --- 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. ---
[GitHub] kafka pull request #1585: KAFKA-3836: KStreamReduce and KTableReduce should ...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/1585 KAFKA-3836: KStreamReduce and KTableReduce should not pass nulls to Deserializers You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka master Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1585.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 #1585 commit 753b05d99e05b535d75caf69997eea0503682e42 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2016-07-04T21:58:28Z MINOR:KStreamReduce and KTableReduce should not pass nulls to Deserializers --- 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. ---
[GitHub] kafka pull request #1569: Kafka 3836: KStreamReduce and KTableReduce should ...
GitHub user jeyhunkarimov opened a pull request: https://github.com/apache/kafka/pull/1569 Kafka 3836: KStreamReduce and KTableReduce should not pass nulls to Deserializers You can merge this pull request into a Git repository by running: $ git pull https://github.com/jeyhunkarimov/kafka KAFKA-3836 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1569.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 #1569 commit e11b0f1c32a0946078a59f4df196a47c1c567f06 Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2016-06-29T11:47:35Z KAFKA-3836 commit 91afc11b43f922d0c395853d12f9c8f655b9ba8f Author: Jeyhun Karimov <je.kari...@gmail.com> Date: 2016-06-29T11:49:02Z KAFKA-3836 --- 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. ---
