[kafka] branch trunk updated (3e30bf5 -> ff68b60)

[rh...@apache.org]

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

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


    from 3e30bf5  Explain the separate  upgrade paths for consumer groups and Streams (#7516)
     add ff68b60  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     | 205 +++++++++++++++-
 .../runtime/isolation/SamplingTestPlugin.java      | 122 ++++++++++
 .../connect/runtime/isolation/TestPlugins.java     | 267 +++++++++++++++++++++
 .../test/plugins/AliasedStaticField.java           |  75 ++++++
 .../test/plugins/AlwaysThrowException.java}        |  35 ++-
 ...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, 1292 insertions(+), 130 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 connect/runtime/src/test/{java/org/apache/kafka/connect/converters/ShortConverterTest.java => resources/test-plugins/always-throw-exception/test/plugins/AlwaysThrowException.java} (53%)
 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 core/src/main/scala/kafka/metrics/KafkaTimer.scala => 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