[GitHub] kafka pull request #4092: KAFKA-6087: Scanning plugin.path needs to support ...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/4092 KAFKA-6087: Scanning plugin.path needs to support relative symlinks. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-6087-Scanning-plugin.path-needs-to-support-relative-symlinks Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/4092.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 #4092 commit 1348ea60fcdf4a10ff2b27039b2dc7d5ad16141e Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-10-18T23:49:19Z KAFKA-6087: Scanning plugin.path needs to support relative symlinks. ---
[GitHub] kafka pull request #4030: KAFKA-5953: Register all jdbc drivers available in...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/4030 KAFKA-5953: Register all jdbc drivers available in plugin and class paths You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-5953-Connect-classloader-isolation-may-be-broken-for-JDBC-drivers Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/4030.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 #4030 ---
[GitHub] kafka pull request #3932: KAFKA-5867: Log Kafka Connect worker info during s...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3932 KAFKA-5867: Log Kafka Connect worker info during startup You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-5867-Kafka-Connect-applications-should-log-info-message-when-starting-up Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3932.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 #3932 commit 793d5820785f4c0d92e5b6e31b8b196d46abfdd8 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-09-21T11:37:15Z KAFKA-5867: Log Kafka Connect worker info during startup ---
[GitHub] kafka pull request #3707: MINOR: Verify startup of zookeeper service in syst...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3707 MINOR: Verify startup of zookeeper service in system tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka MINOR-Verify-startup-of-zookeeper-service-in-system-tests-by-connecting-to-port Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3707.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 #3707 commit 5bb7b9525aadf71c4659e0b405bd9a40ca8b1a7f Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-08-21T18:46:49Z MINOR: Verify startup of zookeeper service in system 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. ---
[GitHub] kafka pull request #3499: KAFKA-5567: Connect sink worker should commit offs...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3499 KAFKA-5567: Connect sink worker should commit offsets of original topic partitions You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-5567-With-transformations-that-mutate-the-topic-partition-committing-offsets-should-to-refer-to-the-original-topic-partition Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3499.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 #3499 commit b9eeeb12812f0b237b4356717dfc5bf0e252e8e6 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-07-07T05:13:50Z KAFKA-5567: Connect sink worker should commit offsets of original topic partitions. --- 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 #3394: KAFKA-5475: Connector config validation needs to i...
Github user kkonstantine closed the pull request at: https://github.com/apache/kafka/pull/3394 --- 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 #3394: KAFKA-5475: Connector config validation needs to i...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3394 KAFKA-5475: Connector config validation needs to include tranformation types You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-5475-Connector-config-validation-REST-API-endpoint-not-including-fields-for-transformations Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3394.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 #3394 commit 10c4ef7b8785119f42eb48dac237fe017c93b753 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-06-21T10:36:39Z KAFKA-5475: Connector config validation needs to include tranformation types. --- 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 #3326: MINOR: Add unit tests for PluginDesc in Connect.
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3326 MINOR: Add unit tests for PluginDesc in Connect. Related to https://github.com/apache/kafka/pull/3321 You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka MINOR-Add-tests-for-PluginDesc Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3326.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 #3326 commit ba6425846602d07f7271c5e2399a1abcf5236ed4 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-06-13T22:27:28Z MINOR: Add unit tests for PluginDesc in Connect. --- 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 #3321: HOTFIX: Handle Connector version returning 'null' ...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3321 HOTFIX: Handle Connector version returning 'null' during plugin loading. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka HOTFIX-Handle-null-version-returned-from-Connector-interface-during-plugin-loading Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3321.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 #3321 commit 72dc8982ae755cda5ba463344fe0857962e4914a Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-06-13T19:02:32Z HOTFIX: Handle Connector version returning 'null' during plugin loading. --- 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 #3197: MINOR: Set log level for org.reflections to ERROR.
Github user kkonstantine closed the pull request at: https://github.com/apache/kafka/pull/3197 --- 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 #3197: MINOR: Set log level for org.reflections to ERROR.
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3197 MINOR: Set log level for org.reflections to ERROR. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka MINOR-Set-log-level-for-org-reflections-to-error Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3197.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 #3197 commit 24ec8bbea3f800de3e264dfdd5734c9b699ed25a Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-06-01T20:32:48Z MINOR: Set log level for org.reflections to ERROR. --- 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 #3173: MINOR: Traverse plugin path recursively in connect
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3173 MINOR: Traverse plugin path recursively in connect You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka MINOR-Traverse-plugin-path-recursively-in-Connect Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3173.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 #3173 commit 20978460c18a85ae263e28ab0578dccc9c90f366 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-30T23:43:24Z Add depth-first search traversal to load plugin classes. commit 256154c6a08925f929459ff58e9fade797707617 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-31T02:05:00Z Remove iterative search among plugin loaders. --- 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 #3111: HOTFIX: Increase timeouts in distributed connect t...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3111 HOTFIX: Increase timeouts in distributed connect tests. * There's considerably increased logging in DEBUG mode due to the class scanning performed with the new isolation scheme. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka HOTFIX-Increase-timeouts-in-distributed-connect-tests-to-handle-increase-startup-due-to-class-scanning Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3111.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 #3111 commit 5538eaa65d7ed614061d6de52ce7f61f7dd7fcd8 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-21T05:45:40Z HOTFIX: Increase timeouts in distributed connect tests. * There's considerably increased logging due to the class scanning performed with the new isolation scheme in DEBUG mode. --- 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 #3028: KAFKA-3487: Support classloading isolation in Conn...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3028 KAFKA-3487: Support classloading isolation in Connect. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-3487-Support-classloading-isolation-in-Connect Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3028.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 #3028 commit 6e3e92cfadfa7c03090476a0f025b5a6b7989d5c Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-05T00:00:29Z KAFKA-3487: Support classloading isolation in Connect. * Add module.path in worker config. commit 84967f43712dd55523ca33e855fa0252f9cdb677 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-09T23:10:08Z Add isolation package. * Add a delegating class loader * Add per module class loaders * Add module factories commit 7e1169b081c451d0f4a3920e75e0bf1961ee84e8 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-12T00:24:08Z Add config property only for standalone currently. commit d8cd6330c6304267a5d7b07c8ef48aa201d95ac8 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-09T23:19:24Z Add maven-artifact dependency for module versioning. commit 50c8a1b79366ce04231b7c88b9abc36871afc143 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-09T23:21:15Z Replace connector factory with new module factory. commit df22a391e920b2f24ad795df929968cd0d5e2dd1 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-11T18:19:39Z Consolidating Modules factory class. commit ba3a78dbcf10a94a2080d7f7ef87585826c27ea8 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-12T00:20:41Z Setting thread context class loader to a modules loader. --- 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 #3007: HOTFIX: Increase kafkatest startup wait time on Co...
Github user kkonstantine closed the pull request at: https://github.com/apache/kafka/pull/3007 --- 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 #3007: HOTFIX: Increase kafkatest startup wait time on Co...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3007 HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service in 0.10.2 You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka HOTFIX-Align-startup-wait-time-for-ConnectDistributed-service-with-ConnectStandalone-in-kafkatests-0.10.2 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3007.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 #3007 commit ad74f10c2a51764f279843dbc6df8b3f4391cd1f Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-09T21:17:38Z HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service. --- 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 #3006: HOTFIX: Increase kafkatest startup wait time on Co...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/3006 HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka HOTFIX-Align-startup-wait-time-for-ConnectDistributed-service-with-ConnectStandalone-in-kafkatests Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3006.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 #3006 commit ea3255156dc5e584ec8e485c123b4815834308c4 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-05-09T20:24:34Z HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service. --- 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 #2830: KAFKA-5046: Support file rotation in FileStreamSou...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/2830 KAFKA-5046: Support file rotation in FileStreamSource Connector - Detect file rotation/removal in FileStreamSource task. - Extend offset key to include creation time and fileKey attributes. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-5046-Support-file-rotation-in-FileStreamSource-Connector Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2830.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 #2830 commit e9f062bc179c9308d683ea590ebcc90854d6c874 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-04-09T00:14:47Z KAFKA-5046: Support file rotation in FileStreamSource Connector - Detect file rotation/removal in FileStreamSource task. - Extend offset key to include creation time and fileKey attributes. --- 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 #2798: KAFKA-4837: Fix class name comparison in connector...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/2798 KAFKA-4837: Fix class name comparison in connector-plugins REST endpoint You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-4837-Config-validation-in-Connector-plugins-need-to-compare-against-both-canonical-and-simple-class-names Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2798.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 #2798 commit 3acacb85b819e989ab0423093c900e416e1e371d Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2017-04-03T20:42:37Z KAFKA-4837: Fix class name comparison in connector-plugins REST endpoint --- 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 #2211: HOTFIX: Fix bug in readToLogEnd in KafkaBasedLog.
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/2211 HOTFIX: Fix bug in readToLogEnd in KafkaBasedLog. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka HOTFIX-Correctly-read-to-end-of-offsets-log-in-Connect-KafkaBasedLog Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2211.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 #2211 commit 84d7624441ebfdfe29af6491fbb10cad915e6d7e Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-12-05T08:05:29Z HOTFIX Fix bug in readToLogEnd in KafkaBasedLog. --- 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 #2201: KAFKA-4306: Shutdown distributed herder with a tim...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/2201 KAFKA-4306: Shutdown distributed herder with a timeout. Resolves KAFKA-4306: Connect workers won't shut down if brokers are not available KAFKA-4154: Kafka Connect fails to shutdown if it has not completed startup You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-4306-Connect-workers-will-not-shut-down-if-brokers-are-not-available Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2201.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 #2201 commit b1decf8ab09ae8e89288d7548cc7561e2455aa0d Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-11-12T00:55:07Z KAFKA-4306: Shutdown distributed herder with a timeout. Resolves KAFKA-4306: Connect workers won't shut down if brokers are not available KAFKA-4154: Kafka Connect fails to shutdown if it has not completed startup --- 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 #2130: MINOR: Extract SCALA_BINARY_VERSION from SCALA_VER...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/2130 MINOR: Extract SCALA_BINARY_VERSION from SCALA_VERSION Will allow users to set one fewer environment variable if they need to change scala version. Still, SCALA_BINARY_VERSION can be explicitly set. You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka MINOR-Extract-SCALA_BINARY_VERSION-from-SCALA_VERSION Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2130.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 #2130 commit a663178090ba3750dea315d1792d6fce9a97c016 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-11-14T22:03:24Z MINOR: Extract SCALA_BINARY_VERSION from SCALA_VERSION Will allow users to set one fewer environment variable if they need to change scala version. Still, SCALA_BINARY_VERSION can be explicitly set. --- 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 #2126: MINOR: Fix export command for additional env vars ...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/2126 MINOR: Fix export command for additional env vars in connect system tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka MINOR-Fix-formatting-of-env-vars-in-connect-system-test-template Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2126.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 #2126 commit e5f230aef65bd44b52a28cc661e0b51b8205c1c3 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-11-11T21:39:35Z MINOR: Fix export command for additional env vars in connect system 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. ---
[GitHub] kafka pull request #2123: KAFKA-4397: Refactor Connect backing stores for th...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/2123 KAFKA-4397: Refactor Connect backing stores for thread safety You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-4397-Refactor-connect-backing-stores-for-thread-safety Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2123.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 #2123 commit 4a0089081db46049722346397c1a287cd2136fa0 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-11-10T21:48:38Z Change the way startup phase is flagged in config backing store. commit 1a459faafa7206609ccfb7e2d19145e144643a2b Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-11-10T23:44:26Z Finalize fields in config backing store for thread safety. commit 61a614bae99198e54f72b10fcff3e191e0c7b468 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-11-10T23:46:19Z Adapt config backing store tests to changes in constructor. --- 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 #2081: MINOR: Extend mirror maker test to include interce...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/2081 MINOR: Extend mirror maker test to include interceptors You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka MINOR-Extend-mirror-maker-test-to-include-interceptors Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2081.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 #2081 commit b2f323c25f5c2a9f91162357ff5be7d7809339d0 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-09-09T23:14:54Z MINOR: Extend mirror maker's test to include interceptor commit b16434d1f6ab16a648a5497488e8847231a76d9b Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-10-28T18:43:22Z Extend connect service to set heap options and print command. commit a6253d68a046886bb108e77df317298cdbee16fd Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-10-31T23:57:03Z Add field to import external jars for interceptors --- 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 #1995: KAFKA-4254: Update producers metadata before faili...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/1995 KAFKA-4254: Update producers metadata before failing on non-existent ⦠â¦partition You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-4254-Update-producers-metadata-before-failing-on-non-existent-partition Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1995.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 #1995 commit d6ea6b77b879ccd5b2d4980845b991052fd09b88 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-10-08T08:00:00Z KAFKA-4254: Update producers metadata before failing on non-existent partition --- 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 #1909: MINOR: Allow for asynchronous start of producer co...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/1909 MINOR: Allow for asynchronous start of producer consumer in validatio⦠â¦n test You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka MINOR-Async-start-in-produce-consume-validate Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1909.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 #1909 commit d7a77ffb27426e3d369485a6975c0e0bddf03153 Author: Konstantine Karantasis <konstant...@confluent.io> Date: 2016-09-25T21:12:12Z MINOR: Allow for asynchronous start of producer consumer in validation test --- 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 #1788: KAFKA-3008: Parallel start and stop of connectors ...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/1788 KAFKA-3008: Parallel start and stop of connectors and tasks in Connect You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-3008-Parallel-start-and-stop-of-connectors-and-tasks Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1788.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 #1788 commit d1f876d4be7394688f6070169cded7748f8492cf Author: Konstantine Karantasis <k.karanta...@gmail.com> Date: 2016-08-25T05:38:45Z KAFKA-3008: Parallel start and stop of connectors and tasks in Connect Refactoring Worker to make start and stop methods thread safe. commit 938b8ad2cba770dad71d3749b26ae59a3c4c3425 Author: Konstantine Karantasis <k.karanta...@gmail.com> Date: 2016-08-25T21:31:57Z Parallelizing start and stop of connectors and tasks in Distributed Herder --- 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 #1771: KAFKA-2894: WorkerSinkTask should rewind offsets o...
GitHub user kkonstantine opened a pull request: https://github.com/apache/kafka/pull/1771 KAFKA-2894: WorkerSinkTask should rewind offsets on rebalance You can merge this pull request into a Git repository by running: $ git pull https://github.com/kkonstantine/kafka KAFKA-2894-rewind-offsets-on-rebalance Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/1771.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 #1771 commit d14eff6084bafcf5014c8309703faafd96fe7071 Author: Konstantine Karantasis <k.karanta...@gmail.com> Date: 2016-08-22T23:30:27Z KAFKA-2894: WorkerSinkTask should rewind offsets on rebalance --- 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. ---
