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/05/28 13:55:28 UTC
[kafka] branch trunk updated (38c1e96 -> 1c4eb1a)

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 38c1e96  KAFKA-9971: Error Reporting in Sink Connectors (KIP-610) (#8720)
     add 1c4eb1a  KAFKA-9673: Filter and Conditional SMTs (#8699)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/kafka/common/utils/Utils.java  |  12 +
 .../connect/transforms/predicates/Predicate.java   |  53 +++
 .../kafka/connect/runtime/ConnectorConfig.java     | 375 +++++++++++++++------
 .../connect/runtime/PredicatedTransformation.java  |  81 +++++
 .../runtime/isolation/DelegatingClassLoader.java   |  11 +
 .../runtime/isolation/PluginScanResult.java        |   8 +
 .../connect/runtime/isolation/PluginUtils.java     |   2 +-
 .../kafka/connect/runtime/isolation/Plugins.java   |   5 +
 .../kafka/connect/tools/TransformationDoc.java     |   4 +-
 .../kafka/connect/integration/ConnectorHandle.java |  16 +-
 .../integration/MonitorableSinkConnector.java      |   2 +-
 .../integration/MonitorableSourceConnector.java    |   5 +-
 .../kafka/connect/integration/TaskHandle.java      |  16 +-
 ...est.java => TransformationIntegrationTest.java} | 291 ++++++++--------
 .../kafka/connect/runtime/AbstractHerderTest.java  | 110 +++++-
 .../kafka/connect/runtime/ConnectorConfigTest.java | 213 +++++++++++-
 .../runtime/PredicatedTransformationTest.java      | 126 +++++++
 .../connect/runtime/isolation/PluginUtilsTest.java |   7 +
 .../apache/kafka/connect/transforms/Filter.java}   |  45 ++-
 .../transforms/predicates/HasHeaderKey.java        |  67 ++++
 .../transforms/predicates/RecordIsTombstone.java   |  43 +--
 .../transforms/predicates/TopicNameMatches.java    |  77 +++++
 .../transforms/predicates/HasHeaderKeyTest.java    | 123 +++++++
 .../predicates/TopicNameMatchesTest.java           |  93 +++++
 24 files changed, 1468 insertions(+), 317 deletions(-)
 create mode 100644 connect/api/src/main/java/org/apache/kafka/connect/transforms/predicates/Predicate.java
 create mode 100644 connect/runtime/src/main/java/org/apache/kafka/connect/runtime/PredicatedTransformation.java
 copy connect/runtime/src/test/java/org/apache/kafka/connect/integration/{ExampleConnectIntegrationTest.java => TransformationIntegrationTest.java} (51%)
 create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/runtime/PredicatedTransformationTest.java
 copy connect/{runtime/src/test/java/org/apache/kafka/connect/runtime/TestSinkConnector.java => transforms/src/main/java/org/apache/kafka/connect/transforms/Filter.java} (51%)
 create mode 100644 connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKey.java
 copy clients/src/test/java/org/apache/kafka/test/MockPartitioner.java => connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/RecordIsTombstone.java (57%)
 create mode 100644 connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatches.java
 create mode 100644 connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates/HasHeaderKeyTest.java
 create mode 100644 connect/transforms/src/test/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatchesTest.java