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 30CD1200C24 for ; Thu, 9 Feb 2017 01:46:16 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 2F80E160B67; Thu, 9 Feb 2017 00:46:16 +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 51A0B160B49 for ; Thu, 9 Feb 2017 01:46:15 +0100 (CET) Received: (qmail 73703 invoked by uid 500); 9 Feb 2017 00:46:14 -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 73681 invoked by uid 99); 9 Feb 2017 00:46:12 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 09 Feb 2017 00:46:12 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id ECED7C0B31; Thu, 9 Feb 2017 00:46:11 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.102 X-Spam-Level: X-Spam-Status: No, score=-0.102 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, SPF_HELO_PASS=-0.001, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (1024-bit key) header.d=opentable.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id Lnr3-hIfCpZ2; Thu, 9 Feb 2017 00:46:07 +0000 (UTC) Received: from NAM01-BN3-obe.outbound.protection.outlook.com (mail-bn3nam01on0099.outbound.protection.outlook.com [104.47.33.99]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 69FA85FC3D; Thu, 9 Feb 2017 00:46:06 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=opentable.com; s=selector1; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version; bh=7txylzvXFLop6Fxic7rin9SEbTk9ZkgRdL2a4bnge04=; b=JjUV7JS3oqbEw2yxBak9+3mjAgAikQIA1bemNNr7HVmgsuswIrIMQY6tfDvKNOHKdKYxz0tKxy2zs0Nntt057bM5tsoTO619lFl85+J76sc9lxmgtyyHpKkPYHNlCTdAapH/n9td4OtkWsua4c+UZ/YYlFIu8NTj3HHCrefwsr0= Received: from SN1PR0701MB1840.namprd07.prod.outlook.com (10.162.100.157) by CO2PR07MB490.namprd07.prod.outlook.com (10.141.197.143) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384_P384) id 15.1.888.16; Thu, 9 Feb 2017 00:45:56 +0000 Received: from SN1PR0701MB1840.namprd07.prod.outlook.com ([10.162.100.157]) by SN1PR0701MB1840.namprd07.prod.outlook.com ([10.162.100.157]) with mapi id 15.01.0888.026; Thu, 9 Feb 2017 00:45:54 +0000 From: Steven Schlansker To: "dev@kafka.apache.org" CC: "users@kafka.apache.org" Subject: KIP-121 [VOTE]: Add KStream peek method Thread-Topic: KIP-121 [VOTE]: Add KStream peek method Thread-Index: AQHSgm3epamVf+Yw0U+fl3PiBbypGw== Date: Thu, 9 Feb 2017 00:45:54 +0000 Message-ID: <8EDD1E05-3381-431D-B121-8E2DB53A660F@opentable.com> Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: yes X-MS-TNEF-Correlator: authentication-results: spf=none (sender IP is ) smtp.mailfrom=sschlansker@opentable.com; x-ms-exchange-messagesentrepresentingtype: 1 x-originating-ip: [199.16.144.7] x-microsoft-exchange-diagnostics: 1;CO2PR07MB490;7:2ml4ceJGY4zYd2rGmMQFpggOrgOp6ZbW8qt7NFIe/dN9xO2lmFUBQJAec7JxFSzuUoAcyTP0tsjqPn4CW3PEm2dMqbQDks0K2I5UDVYyStXoYhbgjdf8XXi6N/FVyFdxy0RMQ+8rphtPCmue/aLRDswxi/5wCbbbAWkr+YzgfWPmNK/9OxUOk9GKkyKSCuIQ7xD3T710vgl78J9gTuQFX47+uyGAk42z+Am/1/r3epzkzbZBNKjmvxfxGL7A4xT+6S2mGw6SqTGIeT0Ydy3yP+BngvEemtdgy/s5LKoiP1UNatJdTVX4uIp+O4KMbijifppNuH/V4qYmbBjsrT99hQeu7BAN22V2RuVvWrJsbIczDQDQXyLo5RWsQAlyFYulWYFmITA2rLCWt1r9Z2P3dozlbQmEuAZqA9u6p7m0vgJhboJ8fiBebThEaTV1OpouUQBc9/OvMugZItjd26VXC9gzhz6liaIXCv5xwAAJn8at02QMELOb0yiHmu77l4hQixXfrFtTlcFy7WbgZwa8qQ== x-forefront-antispam-report: SFV:SKI;SCL:-1SFV:NSPM;SFS:(10019020)(6009001)(7916002)(39450400003)(199003)(43234003)(189002)(53754006)(6506006)(50986999)(305945005)(7736002)(106116001)(6486002)(66066001)(6306002)(99286003)(77096006)(101416001)(105586002)(345774005)(6512007)(5640700003)(106356001)(3280700002)(3660700001)(99936001)(2906002)(53936002)(36756003)(25786008)(4326007)(6436002)(2351001)(54356999)(83716003)(2900100001)(86362001)(82746002)(450100001)(97736004)(122556002)(2501003)(8676002)(68736007)(6116002)(110136004)(102836003)(3846002)(33656002)(38730400002)(8936002)(1730700003)(5660300001)(81156014)(6916009)(92566002)(81166006)(189998001)(5890100001)(104396002);DIR:OUT;SFP:1102;SCL:1;SRVR:CO2PR07MB490;H:SN1PR0701MB1840.namprd07.prod.outlook.com;FPR:;SPF:None;PTR:InfoNoRecords;A:1;MX:1;LANG:en; x-ms-office365-filtering-correlation-id: ef5f94f8-7586-4fa2-1054-08d4508500ea x-microsoft-antispam: UriScan:;BCL:0;PCL:0;RULEID:(22001);SRVR:CO2PR07MB490; x-microsoft-antispam-prvs: x-exchange-antispam-report-test: UriScan:(166708455590820)(190461294614860)(67729699691378); x-exchange-antispam-report-cfa-test: BCL:0;PCL:0;RULEID:(102415395)(6040375)(601004)(2401047)(5005006)(2017020702029)(20170203043)(8121501046)(3002001)(10201501046)(6041248)(20161123562025)(20161123555025)(20161123560025)(20161123564025)(20161123558025)(6072148);SRVR:CO2PR07MB490;BCL:0;PCL:0;RULEID:;SRVR:CO2PR07MB490; x-forefront-prvs: 02135EB356 received-spf: None (protection.outlook.com: opentable.com does not designate permitted sender hosts) spamdiagnosticoutput: 1:99 spamdiagnosticmetadata: NSPM Content-Type: multipart/signed; boundary="Apple-Mail=_782EFE3D-C6F3-4CC1-B456-6E77C90B7797"; protocol="application/pgp-signature"; micalg=pgp-sha256 MIME-Version: 1.0 X-OriginatorOrg: opentable.com X-MS-Exchange-CrossTenant-originalarrivaltime: 09 Feb 2017 00:45:54.0853 (UTC) X-MS-Exchange-CrossTenant-fromentityheader: Hosted X-MS-Exchange-CrossTenant-id: fd157fd5-1236-4610-b786-2578dee6ff2c X-MS-Exchange-Transport-CrossTenantHeadersStamped: CO2PR07MB490 archived-at: Thu, 09 Feb 2017 00:46:16 -0000 --Apple-Mail=_782EFE3D-C6F3-4CC1-B456-6E77C90B7797 Content-Transfer-Encoding: quoted-printable Content-Type: text/plain; charset=us-ascii Hi everyone, Thank you for constructive feedback on KIP-121, = KStream.peek(ForeachAction) ; it seems like it is time to call a vote which I hope will pass easily :) = https://cwiki.apache.org/confluence/display/KAFKA/KIP-121%3A+Add+KStream+p= eek+method I believe the PR attached is already in good shape to consider merging: https://github.com/apache/kafka/pull/2493 Thanks! Steven --Apple-Mail=_782EFE3D-C6F3-4CC1-B456-6E77C90B7797 Content-Transfer-Encoding: 7bit Content-Disposition: attachment; filename="signature.asc" Content-Type: application/pgp-signature; name="signature.asc" Content-Description: Message signed with OpenPGP using GPGMail -----BEGIN PGP SIGNATURE----- iQIcBAEBCAAGBQJYm7vBAAoJEMKENA5ej+CnLc8QAKceCleZW/LHTHzdzgj76+r6 Arv3ho8fyEwgDy3ziopB6vBQkpUgqofYOpokOqq75zkfz3Ki4oguXpy7eZp61TCZ Gh348lzVw/37SEFaZmFvRHPNGbNiAHbh6OpJY+PZ89YkNd3h7OoHxrWVHFX6kK+5 K8oiJue2VHkWQwAt1pwKqSLcGEWynosiLFh3zUJsIl7xd4ldReP7/0/72jY9sTm2 giCiDzb29uBcflE/DPWf6pN/trc7xLbsFL4QHpvqtgHSsafZP3gcWv6z2JAeqbk4 vju10fkGmnch2J49TajhFl8Ze9L4/467PGHcZyELIfXcxjuqBUL4KHzBI8Lte9AS yJY/sJXwilLwBIWPEWw4vFP178dJFOr0/snk6kqtFy0mIJdmIThegOsRFog0fcjl Y2/LjiX/ERQcRr0niTfhcm0TPyPWFbOnVFBdgziy6KR07U59mApOYAiRcmQnZZ7Z EG2oCKfQQ2PD3GUuAWplsIG1CcG84sCLCm0FvAphMofEs81hkNo4XGGwuSXLKQFB uaqlYVL41RRjt++y5yTaxK2hn1sTONiOZ/0dfQ++R2Up5SGlAvaICqPuFLpTtIxA K7vfdEPfzwAtQygybEBeamFWUGnQf70bI5eDgxwtC/gKmZXqiCr21hebHDLaxVLZ z25BU9xtzkKRPzoVtCZv =/R12 -----END PGP SIGNATURE----- --Apple-Mail=_782EFE3D-C6F3-4CC1-B456-6E77C90B7797--