You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by to...@apache.org on 2021/04/16 14:13:30 UTC

[kafka] branch trunk updated (a6b22f3 -> f8f1769)

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

tombentley pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from a6b22f3  MINOR: fix package name in integration test (#10400)
     add f8f1769  KIP-145: Add SMTs, HeaderFrom, DropHeaders and InsertHeader (#9549)

No new revisions were added by this update.

Summary of changes:
 .../kafka/connect/tools/TransformationDoc.java     |   8 +-
 .../kafka/connect/transforms/DropHeaders.java      |  74 +++++
 .../kafka/connect/transforms/HeaderFrom.java       | 238 ++++++++++++++
 .../kafka/connect/transforms/InsertHeader.java     |  77 +++++
 .../kafka/connect/transforms/DropHeadersTest.java  | 117 +++++++
 .../kafka/connect/transforms/HeaderFromTest.java   | 359 +++++++++++++++++++++
 .../kafka/connect/transforms/InsertHeaderTest.java | 121 +++++++
 docs/connect.html                                  |   3 +
 8 files changed, 996 insertions(+), 1 deletion(-)
 create mode 100644 connect/transforms/src/main/java/org/apache/kafka/connect/transforms/DropHeaders.java
 create mode 100644 connect/transforms/src/main/java/org/apache/kafka/connect/transforms/HeaderFrom.java
 create mode 100644 connect/transforms/src/main/java/org/apache/kafka/connect/transforms/InsertHeader.java
 create mode 100644 connect/transforms/src/test/java/org/apache/kafka/connect/transforms/DropHeadersTest.java
 create mode 100644 connect/transforms/src/test/java/org/apache/kafka/connect/transforms/HeaderFromTest.java
 create mode 100644 connect/transforms/src/test/java/org/apache/kafka/connect/transforms/InsertHeaderTest.java