kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-3209) Support single message transforms in Kafka Connect
Date Fri, 27 Jan 2017 07:27:24 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-3209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15842359#comment-15842359

ASF GitHub Bot commented on KAFKA-3209:

GitHub user ewencp opened a pull request:


    KAFKA-3209: KIP-66: Flatten and Cast single message transforms


You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/ewencp/kafka kafka-3209-even-more-transforms

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2458
commit 14692133dc80552410b2b0eac76b9fca8a73afe1
Author: Ewen Cheslack-Postava <me@ewencp.org>
Date:   2017-01-27T07:26:02Z

    KAFKA-3209: KIP-66: Flatten and Cast single message transforms


> 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:
> 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

View raw message