[kafka] branch 2.0 updated (beaabf1 -> 111176d)

[rh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rhauch pushed a change to branch 2.0
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from beaabf1  KAFKA-8945/KAFKA-8947 backport (#7533)
     add 111176d  KAFKA-8340, KAFKA-8819: Use PluginClassLoader while statically initializing plugins (#7315)

No new revisions were added by this update.

Summary of changes:
 checkstyle/import-control.xml                      |   1 +
 .../org/apache/kafka/connect/runtime/Worker.java   |   4 +-
 .../runtime/isolation/DelegatingClassLoader.java   |  51 ++--
 .../kafka/connect/runtime/isolation/Plugins.java   | 131 +++++-----
 .../isolation/DelegatingClassLoaderTest.java       |  23 ++
 .../connect/runtime/isolation/PluginsTest.java     | 206 +++++++++++++++-
 .../runtime/isolation/SamplingTestPlugin.java      | 122 ++++++++++
 .../connect/runtime/isolation/TestPlugins.java     | 267 +++++++++++++++++++++
 .../test/plugins/AliasedStaticField.java           |  75 ++++++
 .../test/plugins/AlwaysThrowException.java         |  44 ++--
 ...che.kafka.common.config.provider.ConfigProvider |   2 +-
 .../test/plugins/SamplingConfigProvider.java       | 101 ++++++++
 .../test/plugins/SamplingConfigurable.java         |  79 ++++++
 .../test/plugins/SamplingConverter.java            |  76 ++++++
 .../test/plugins/SamplingHeaderConverter.java      |  89 +++++++
 .../services/test.plugins.ServiceLoadedClass       |   2 +-
 .../test/plugins/ServiceLoadedClass.java           |  39 +--
 .../test/plugins/ServiceLoadedSubclass.java        |  35 +--
 .../test/plugins/ServiceLoaderPlugin.java          |  85 +++++++
 19 files changed, 1291 insertions(+), 141 deletions(-)
 create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/SamplingTestPlugin.java
 create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/TestPlugins.java
 create mode 100644 connect/runtime/src/test/resources/test-plugins/aliased-static-field/test/plugins/AliasedStaticField.java
 copy clients/src/main/java/org/apache/kafka/common/serialization/FloatDeserializer.java => connect/runtime/src/test/resources/test-plugins/always-throw-exception/test/plugins/AlwaysThrowException.java (56%)
 copy {clients/src/main/resources => connect/runtime/src/test/resources/test-plugins/sampling-config-provider}/META-INF/services/org.apache.kafka.common.config.provider.ConfigProvider (93%)
 create mode 100644 connect/runtime/src/test/resources/test-plugins/sampling-config-provider/test/plugins/SamplingConfigProvider.java
 create mode 100644 connect/runtime/src/test/resources/test-plugins/sampling-configurable/test/plugins/SamplingConfigurable.java
 create mode 100644 connect/runtime/src/test/resources/test-plugins/sampling-converter/test/plugins/SamplingConverter.java
 create mode 100644 connect/runtime/src/test/resources/test-plugins/sampling-header-converter/test/plugins/SamplingHeaderConverter.java
 copy clients/src/main/resources/META-INF/services/org.apache.kafka.common.config.provider.ConfigProvider => connect/runtime/src/test/resources/test-plugins/service-loader/META-INF/services/test.plugins.ServiceLoadedClass (93%)
 copy clients/src/main/java/org/apache/kafka/common/errors/RecordBatchTooLargeException.java => connect/runtime/src/test/resources/test-plugins/service-loader/test/plugins/ServiceLoadedClass.java (56%)
 copy clients/src/main/java/org/apache/kafka/common/errors/RetriableException.java => connect/runtime/src/test/resources/test-plugins/service-loader/test/plugins/ServiceLoadedSubclass.java (59%)
 create mode 100644 connect/runtime/src/test/resources/test-plugins/service-loader/test/plugins/ServiceLoaderPlugin.java