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 5727b24 KAFKA-7052 Avoiding NPE in ExtractField SMT in case of
non-existent fields (#8059)
add 0f14aef MINOR: Start using Response and replace IOException in
EmbeddedConnectCluster for failures (#8055)
No new revisions were added by this update.
Summary of changes:
.../integration/ConnectWorkerIntegrationTest.java | 124 ++------
.../RebalanceSourceConnectorsIntegrationTest.java | 145 +++-------
.../integration/RestExtensionIntegrationTest.java | 9 +-
.../SessionedProtocolIntegrationTest.java | 8 +-
.../util/clusters/EmbeddedConnectCluster.java | 317 ++++++++++++++-------
.../clusters/EmbeddedConnectClusterAssertions.java | 246 ++++++++++++++++
.../util/clusters/EmbeddedKafkaCluster.java | 25 +-
7 files changed, 561 insertions(+), 313 deletions(-)
create mode 100644
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectClusterAssertions.java
