[GitHub] kafka pull request #2587: KAFKA-4789: Added support to ProcessorTopologyTest...
Github user hrafzali closed the pull request at: https://github.com/apache/kafka/pull/2587 --- 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 #2590: KAFKA-4789: Added support to ProcessorTopologyTest...
GitHub user hrafzali opened a pull request: https://github.com/apache/kafka/pull/2590 KAFKA-4789: Added support to ProcessorTopologyTestDriver to forward timestamps to internal topics This resolves the issue in the ProcessorTopologyTestDriver that the extracted timestamp is not forwarded with the produced record to the internal topics. JIRA ticket: https://issues.apache.org/jira/browse/KAFKA-4789 The contribution is my original work and I license the work to the project under the project's open source license. @guozhangwang @dguy You can merge this pull request into a Git repository by running: $ git pull https://github.com/hrafzali/kafka KAFKA-4789_ProcessorTopologyTestDriver_timestamp Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2590.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 #2590 commit 579a65a691dd9d07e4bf945badfe18c261da8540 Author: Hamidreza Afzali Date: 2017-02-23T10:53:18Z KAFKA-4789: Added support to ProcessorTopologyTestDriver to forward extracted timestamps to internal topics --- 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 #2629: KAFKA-4828: ProcessorTopologyTestDriver does not w...
GitHub user hrafzali opened a pull request: https://github.com/apache/kafka/pull/2629 KAFKA-4828: ProcessorTopologyTestDriver does not work when using through This resolves the following issues in the ProcessorTopologyTestDriver: - It should not create an internal changelog topic when using `through()` - It should forward the produced record back into the topology if it is to a source topic Jira ticket: https://issues.apache.org/jira/browse/KAFKA-4828 The contribution is my original work and I license the work to the project under the project's open source license. You can merge this pull request into a Git repository by running: $ git pull https://github.com/hrafzali/kafka KAFKA-4828_ProcessorTopologyTestDriver_through Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2629.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 #2629 commit 93b6e2f185866fd4ae50624085ded17f9cb4cac2 Author: Hamidreza Afzali Date: 2017-03-01T19:01:47Z KAFKA-4828: ProcessorTopologyTestDriver gets names of stores and changelog topics from the topology commit 884c8d40ef1c3a235fd89f863fd84392d9abe8ae Author: Hamidreza Afzali Date: 2017-03-02T21:50:58Z KAFKA-4828: Added support to ProcessorTopologyTestDriver for processing records produced to source topics --- 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 #2587: KAFKA-4461: Added support to ProcessorTopologyTest...
GitHub user hrafzali opened a pull request: https://github.com/apache/kafka/pull/2587 KAFKA-4461: Added support to ProcessorTopologyTestDriver to forward timestamps to internal topics This resolves the issue in the ProcessorTopologyTestDriver that the extracted timestamp is not forwarded with the produced record to the internal topics. JIRA ticket: https://issues.apache.org/jira/browse/KAFKA-4789 The contribution is my original work and I license the work to the project under the project's open source license. @guozhangwang @dguy You can merge this pull request into a Git repository by running: $ git pull https://github.com/hrafzali/kafka KAFKA-4789_ProcessorTopologyTestDriver_timestamp Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2587.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 #2587 commit ad6db45916f28971470c0522584c2dca02ffae76 Author: Hamidreza Afzali Date: 2017-02-23T10:53:18Z KAFKA-4461: Added support to ProcessorTopologyTestDriver to forward extracted timestamps to internal topics. --- 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 #3206: KAFKA-5368 Kafka Streams skipped-records-rate sens...
GitHub user hrafzali opened a pull request: https://github.com/apache/kafka/pull/3206 KAFKA-5368 Kafka Streams skipped-records-rate sensor bug This resolved the issue with Kafka Streams skipped records sensor reporting wrong values. Jira ticket: https://issues.apache.org/jira/browse/KAFKA-5368 The contribution is my original work and I license the work to the project under the project's open source license. You can merge this pull request into a Git repository by running: $ git pull https://github.com/hrafzali/kafka KAFKA-5368_skipped-records-sensor-bug Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3206.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 #3206 commit db4e424c55d63b9172de563fb559002f435b7f01 Author: Hamidreza Afzali Date: 2017-06-02T09:43:32Z KAFKA-5368 Kafka Streams skipped-records-rate sensor bug --- 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. ---
