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 DE3A2200B35 for ; Tue, 5 Jul 2016 19:00:25 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id DCFB7160A60; Tue, 5 Jul 2016 17:00:25 +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 315CA160A2C for ; Tue, 5 Jul 2016 19:00:25 +0200 (CEST) Received: (qmail 43530 invoked by uid 500); 5 Jul 2016 17:00:24 -0000 Mailing-List: contact dev-help@apex.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.apache.org Delivered-To: mailing list dev@apex.apache.org Received: (qmail 43519 invoked by uid 99); 5 Jul 2016 17:00:24 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 05 Jul 2016 17:00:24 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id EE377C00EA for ; Tue, 5 Jul 2016 17:00:22 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -5.446 X-Spam-Level: X-Spam-Status: No, score=-5.446 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-1.426] autolearn=disabled Received: from mx2-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id HACvrPyJ5Z3S for ; Tue, 5 Jul 2016 17:00:22 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with SMTP id 19E415F4E5 for ; Tue, 5 Jul 2016 17:00:21 +0000 (UTC) Received: (qmail 43202 invoked by uid 99); 5 Jul 2016 17:00:21 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 05 Jul 2016 17:00:21 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 370DEE01C1; Tue, 5 Jul 2016 17:00:21 +0000 (UTC) From: sandeshh To: dev@apex.incubator.apache.org Reply-To: dev@apex.incubator.apache.org References: In-Reply-To: Subject: [GitHub] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output operator: 0.9.... Content-Type: text/plain Message-Id: <20160705170021.370DEE01C1@git1-us-west.apache.org> Date: Tue, 5 Jul 2016 17:00:21 +0000 (UTC) archived-at: Tue, 05 Jul 2016 17:00:26 -0000 GitHub user sandeshh reopened a pull request: https://github.com/apache/apex-malhar/pull/298 [APEXMALHAR-2086] Kafka output operator: 0.9.0 Kafka output exactly once operator and the regular output operator. You can merge this pull request into a Git repository by running: $ git pull https://github.com/sandeshh/apex-malhar APEXMALHAR-2086 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/apex-malhar/pull/298.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #298 ---- commit 6bf316da76bf1d1871f52a114a307c05ff652376 Author: sandeshh Date: 2016-05-25T15:56:56Z Kafka 0.9.0 output operators and unit tests. 1. Abstract Base class 2. Kafka Output operator 3. Exactly Once output operator Key in the Kafka message is used by the operator to track the tuples written by it. ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastructure@apache.org or file a JIRA ticket with INFRA. ---