[beam] branch master updated (ffe1c813ad7 -> e06dade42e8)

[yh...@apache.org]

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

yhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from ffe1c813ad7 Merge pull request #27742 Fix error about monitoring_infos closure.
     add e06dade42e8 Add Kafka Resource managers to manage kafka resources in tests. (#27739)

No new revisions were added by this update.

Summary of changes:
 it/{cassandra => kafka}/build.gradle               |  11 +-
 .../apache/beam/it/kafka/KafkaResourceManager.java | 301 +++++++++++++++++++++
 .../it/kafka/KafkaResourceManagerException.java}   |  11 +-
 .../beam/it/kafka/KafkaResourceManagerUtils.java}  |  39 +--
 .../org/apache/beam/it/kafka}/package-info.java    |   4 +-
 .../beam/it/kafka/KafkaResourceManagerTest.java    | 178 ++++++++++++
 .../it/kafka/KafkaResourceManagerUtilsTest.java    |  17 +-
 settings.gradle.kts                                |   1 +
 8 files changed, 522 insertions(+), 40 deletions(-)
 copy it/{cassandra => kafka}/build.gradle (75%)
 create mode 100644 it/kafka/src/main/java/org/apache/beam/it/kafka/KafkaResourceManager.java
 copy it/{jdbc/src/main/java/org/apache/beam/it/jdbc/JDBCResourceManagerException.java => kafka/src/main/java/org/apache/beam/it/kafka/KafkaResourceManagerException.java} (73%)
 copy it/{cassandra/src/main/java/org/apache/beam/it/cassandra/CassandraResourceManagerUtils.java => kafka/src/main/java/org/apache/beam/it/kafka/KafkaResourceManagerUtils.java} (55%)
 copy it/{elasticsearch/src/main/java/org/apache/beam/it/elasticsearch => kafka/src/main/java/org/apache/beam/it/kafka}/package-info.java (83%)
 create mode 100644 it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaResourceManagerTest.java
 copy sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sqs/SqsUnboundedSourceTest.java => it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaResourceManagerUtilsTest.java (66%)