From dev-return-92891-archive-asf-public=cust-asf.ponee.io@kafka.apache.org Mon Apr 2 16:12:05 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 40364180675 for ; Mon, 2 Apr 2018 16:12:05 +0200 (CEST) Received: (qmail 8219 invoked by uid 500); 2 Apr 2018 14:12:03 -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 7077 invoked by uid 99); 2 Apr 2018 14:12:02 -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; Mon, 02 Apr 2018 14:12:02 +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 3ACEF18048D for ; Mon, 2 Apr 2018 14:12:02 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.898 X-Spam-Level: * X-Spam-Status: No, score=1.898 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com 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 6vlZ5Z86htUn for ; Mon, 2 Apr 2018 14:11:58 +0000 (UTC) Received: from mail-wr0-f175.google.com (mail-wr0-f175.google.com [209.85.128.175]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id D9E745F4A8 for ; Mon, 2 Apr 2018 14:11:57 +0000 (UTC) Received: by mail-wr0-f175.google.com with SMTP id o8so13978772wra.1 for ; Mon, 02 Apr 2018 07:11:57 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=E2GA3Kt8JKn3v/oqG8B7JevA0qB46n7VWykOQdwTSTA=; b=d6jNP6CnjYd7teFFcXiYYdmzDcov1C83Tu/GgWbKua2vYZ1fmtNk2iTPWMkMkFobHD E2t3ea0kD8jJfCW/ly30oyEgOAPlYdc7kb4xYqf6SX2Ynvl7cWV9zj/Pf0nkBpMVZIZn H6USyXFYDuusX8tkzzDJisg96bkFWM//bvnpuESvicOzCI5lRK9zSds26MThwBUNi9WS ipRSmhXLkx0/kMYC0KAu7VxAMH4H6N5w7qh3tjt2nLAuqHINv6q6+FIhdQHWcaTU2Qqg tMqbquCKCdxnQRYDdlAr9Ybkz3LJ/2156buBQxIZbeGjfbOjFVWRNpzxqGYMRiT5eX7x qzXw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=E2GA3Kt8JKn3v/oqG8B7JevA0qB46n7VWykOQdwTSTA=; b=JxFsgMIUaJstuu8zFxmZc5Wl35Q5Hh7wonrLBbvoKZdVcTBRqqG3HFMYKe+ace1AJW yZkZW1PSVIkEiMCVOAFhYvYAAb8W/ocmQQ+X+asfROQnDhnsHN+21yYoZFB4z8U11TXK U8aFYfOeAhxeI1EJZT5COkYgjMLqPpwNdpSAEWzkzYey8yAus8O5tL/kjWZurG3Bvqjs rCrP+Pk1RrtgRvHbGMaEbLypD3R28AxeGkVj/HuVgxKxhdIiPCzBZzhpiixx7y6Fzdxt 23WNk79oT8D6niwdVRcatFVDYJ6/1hNzhJE47nbzrSf7JnzKEoIB51Wa0Yd3i7f/eCrf F+CA== X-Gm-Message-State: ALQs6tAhLlkDg+4wV4LrOKbiERGdD14W1fXEXHcfB8uwUc0OFwo6UFdO GaXX13Qk+zMiokcDn4oKt/zHl3Kq3X+t+h0gzEXI5A== X-Google-Smtp-Source: AIpwx49T/PnGAE1MIhDfc/NX7ORwlX62/WPTmngEUICre/jFMY5BYwBDFvg4OwLD0yEKswt+xka6GnwC3xKFJMq5hVQ= X-Received: by 2002:a19:4e5d:: with SMTP id c90-v6mr5622784lfb.98.1522678310745; Mon, 02 Apr 2018 07:11:50 -0700 (PDT) MIME-Version: 1.0 Received: by 2002:a19:6910:0:0:0:0:0 with HTTP; Mon, 2 Apr 2018 07:11:50 -0700 (PDT) In-Reply-To: References: From: Bill Bejeck Date: Mon, 2 Apr 2018 10:11:50 -0400 Message-ID: Subject: Re: [VOTE] KIP-274: Kafka Streams Skipped Records Metrics To: dev@kafka.apache.org Content-Type: multipart/alternative; boundary="000000000000d1bafe0568de2bd9" --000000000000d1bafe0568de2bd9 Content-Type: text/plain; charset="UTF-8" Thanks for the KIP. +1 -Bill On Mon, Apr 2, 2018 at 10:09 AM, John Roesler wrote: > Dear Kafka community, > > I am proposing KIP-274 to improve visibility when Streams skips invalid > records. > > The proposal is to simplify the metrics and add warning logs. > > Please find details in the wiki: > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 274%3A+Kafka+Streams+Skipped+Records+Metrics > > Thanks, > > -John > --000000000000d1bafe0568de2bd9--