This is an automated email from the ASF dual-hosted git repository.
cegerton pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 8611d28b2e2 KAFKA-15392: Prevent shadowing RestServer shutdown
exceptions (#14277)
add 1c5020e1429 KAFKA-13327: Gracefully report connector validation errors
instead of returning 500 responses (#14303)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/runtime/AbstractHerder.java | 5 +-
.../kafka/connect/runtime/ConnectorConfig.java | 5 +-
.../kafka/connect/runtime/SinkConnectorConfig.java | 74 +++--
.../runtime/distributed/DistributedHerder.java | 29 +-
.../ConnectorValidationIntegrationTest.java | 336 +++++++++++++++++++++
.../kafka/connect/runtime/AbstractHerderTest.java | 27 +-
.../runtime/distributed/DistributedHerderTest.java | 27 ++
.../clusters/EmbeddedConnectClusterAssertions.java | 22 +-
8 files changed, 488 insertions(+), 37 deletions(-)
create mode 100644
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorValidationIntegrationTest.java