You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2020/02/11 20:50:14 UTC
[kafka] branch trunk updated (5727b24 -> 0f14aef)
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