Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id BC8F1200C06 for ; Fri, 27 Jan 2017 08:31:28 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id BB3A1160B60; Fri, 27 Jan 2017 07:31:28 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 11549160B47 for ; Fri, 27 Jan 2017 08:31:27 +0100 (CET) Received: (qmail 32520 invoked by uid 500); 27 Jan 2017 07:31:26 -0000 Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list dev@kafka.apache.org Received: (qmail 32509 invoked by uid 99); 27 Jan 2017 07:31:26 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 27 Jan 2017 07:31:26 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 15A2C18C869 for ; Fri, 27 Jan 2017 07:31:26 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -1.199 X-Spam-Level: X-Spam-Status: No, score=-1.199 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RP_MATCHES_RCVD=-2.999] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id yf_fU92LkAHT for ; Fri, 27 Jan 2017 07:31:25 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id 43FE85F30D for ; Fri, 27 Jan 2017 07:31:25 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id A1044E0236 for ; Fri, 27 Jan 2017 07:31:24 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 61B7C20D75 for ; Fri, 27 Jan 2017 07:31:24 +0000 (UTC) Date: Fri, 27 Jan 2017 07:31:24 +0000 (UTC) From: "Ewen Cheslack-Postava (JIRA)" To: dev@kafka.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (KAFKA-3209) Support single message transforms in Kafka Connect MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 27 Jan 2017 07:31:28 -0000 [ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3209: ----------------------------------------- Status: Patch Available (was: Reopened) > Support single message transforms in Kafka Connect > -------------------------------------------------- > > Key: KAFKA-3209 > URL: https://issues.apache.org/jira/browse/KAFKA-3209 > Project: Kafka > Issue Type: Improvement > Components: KafkaConnect > Reporter: Neha Narkhede > Assignee: Ewen Cheslack-Postava > Priority: Blocker > Labels: needs-kip > Fix For: 0.10.2.0 > > > Users should be able to perform light transformations on messages between a connector and Kafka. This is needed because some transformations must be performed before the data hits Kafka (e.g. filtering certain types of events or PII filtering). It's also useful for very light, single-message modifications that are easier to perform inline with the data import/export. -- This message was sent by Atlassian JIRA (v6.3.4#6332)