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 04C23200BF3 for ; Thu, 5 Jan 2017 11:37:28 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 01A3C160B27; Thu, 5 Jan 2017 10:37: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 23D89160B26 for ; Thu, 5 Jan 2017 11:37:26 +0100 (CET) Received: (qmail 39559 invoked by uid 500); 5 Jan 2017 10:37:21 -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 39547 invoked by uid 99); 5 Jan 2017 10:37:21 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 05 Jan 2017 10:37:20 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 7B5991A05CB for ; Thu, 5 Jan 2017 10:37:20 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.398 X-Spam-Level: * X-Spam-Status: No, score=1.398 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FREEMAIL_REPLY=1, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.001, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-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 (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id vOa_NRp6HlQO for ; Thu, 5 Jan 2017 10:37:19 +0000 (UTC) Received: from mail-wj0-f171.google.com (mail-wj0-f171.google.com [209.85.210.171]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id BE01D5F286 for ; Thu, 5 Jan 2017 10:37:18 +0000 (UTC) Received: by mail-wj0-f171.google.com with SMTP id tq7so253376323wjb.0 for ; Thu, 05 Jan 2017 02:37:18 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=from:content-transfer-encoding:mime-version:subject:date:references :to:in-reply-to:message-id; bh=4MHUyyPj36G5iv1gN4snrVwO/8t0KGMaXAESXlkYbGo=; b=LHPkHit1XQwjVS9Y/n++7ahiLxbhPuOG3PaS4k/sIntpalBvOwkZMIcJrhzbYSQiOo kFcumAh123Ooo1GQQqvAt7/GEn0om74HMl6vFlh6Rpbt99+4kF52eipnOw+Xs8h0MZQX OIHkj6xaXjsvTFK6I0izdmXggde2YWx3awXg1CI+GMpUI1aq7HZ6aOfRKhkuGJApKocT bT5oSbpn5p0gQZ70jxOKrGmYD7+0rXMqiiCCdkoaQvY9KHHEnCsBs8TzTN/jk9J420uo +1YuMFi5lkJd7pfF0T0HLCPxpn3EKxd5p4DeXqa5YVC1maCU70dO7Hibs8dki7NaE3O3 tUpA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:content-transfer-encoding:mime-version :subject:date:references:to:in-reply-to:message-id; bh=4MHUyyPj36G5iv1gN4snrVwO/8t0KGMaXAESXlkYbGo=; b=kES5nnqmkZBBQ4ccl1PSfkKFQsEJhtLqugcrEPNTptXK0q9XYtlsja09iI4Aoh2PLl vUMxMQXwMM/CHrXj4qYgrXS7DYrWy//UInav15BDudZo7a6TU0Wlq+sleugftndxBNWo YFpv0TccGc6ppAhLuIPcG0GzfruazQEwl2iZx9aH+2YjFrfaWc5fE/jPuzanapbjNUZ7 t6PsBUz4PCBCvWCbkReiu556yjJwfWBbDqRKtvPcDsfKXOKhr9x4w+W2qkAFsD0hx7Qm kVQcLYiqhjp7ccOLD7uiYCR9BTXkGN9DvUlJLmDrX4EDF7y4ZzDvlRLS/yHytAXnkpQV A70A== X-Gm-Message-State: AIkVDXI8E40HZLHBvFS2zsLvW2oEOwt+sy6O20NZQ2EdiiW3+1qv3rmOLO+kOsRi5SgE5A== X-Received: by 10.194.158.229 with SMTP id wx5mr3987385wjb.174.1483612637535; Thu, 05 Jan 2017 02:37:17 -0800 (PST) Received: from [192.168.0.5] (cpc91224-cmbg18-2-0-cust223.5-4.cable.virginm.net. [81.106.228.224]) by smtp.gmail.com with ESMTPSA id i132sm99230388wmf.14.2017.01.05.02.37.16 for (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Thu, 05 Jan 2017 02:37:16 -0800 (PST) From: Eno Thereska Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: quoted-printable Mime-Version: 1.0 (Mac OS X Mail 10.2 \(3259\)) Subject: Re: [DISCUSS] KIP-105: Addition of Record Level for Sensors Date: Thu, 5 Jan 2017 10:37:16 +0000 References: To: dev@kafka.apache.org In-Reply-To: Message-Id: <0EE46D5C-9E68-4202-A135-4A0F25FD3DD9@gmail.com> X-Mailer: Apple Mail (2.3259) archived-at: Thu, 05 Jan 2017 10:37:28 -0000 Correct on 2. Guozhang: the sensor will be registered and polled by a = reporter, but the metrics associated with it will not be updated.=20 That would allow a user to have, for example, a debug dashboard and an = info dashboard. Updated KIP to make this clear. Thanks Eno > On 4 Jan 2017, at 18:00, Aarti Gupta wrote: >=20 > Thanks for the review, Guozhang, >=20 > Addressed 2 out of the three comments, >=20 > 1. Fixed and updated KIP (swapped code variable name > METRICS_RECORD_LEVEL_CONFIG with config name metrics.record.level) >=20 > 3. >>Could you elaborate on the "shouldRecord()" function, e.g. which = class > it will be added to? Does it contain any parameters? >=20 > Added more details on shouldRecord() on the KIP >=20 > In Sensor.java the shouldRecord() method is used to compare the value = of > metric record level in the consumer config and the RecordLevel = associated > with the sensor, to determine if metrics should recorded. >=20 > =46rom Sensor.java >=20 > /** > * @return true if the sensor's record level indicates that the metric > will be recorded, false otherwise > */ > public boolean shouldRecord() { > return this.recordLevel.shouldRecord(config.recordLevel()); > } >=20 > =46rom nested enum, Sensor.RecordLevel >=20 > public boolean shouldRecord(final RecordLevel configLevel) { > if (configLevel.equals(DEBUG)) { > return true; > } else { > return configLevel.equals(this); > } > } >=20 >=20 > 2. Need to discuss with Eno. >=20 >=20 > Thanks! >=20 > aarti >=20 >=20 >=20 >=20 >=20 > On Tue, Jan 3, 2017 at 2:27 PM, Guozhang Wang = wrote: >=20 >> LGTM overall. A few comments below: >>=20 >> 1. "METRICS_RECORD_LEVEL_CONFIG" is the internal code's variable = name, but >> not the real config string, I think it is `metrics.record.level` = instead? >>=20 >> 2. In the Motivation section, as in "This associates each sensor with = a >> record level ... only if the metric config of the client requires = these >> metrics to be recorded." >>=20 >> Could you elaborate this a bit more, for example, will the sensor = ever be >> registered in the reporter if its level is not allowed in the client >> config? Or it will be registered but never polled? Or it will be = registered >> and polled, but recorded? >>=20 >> =46rom PR 1446 it seems to be the last case, i.e. the sensor will = have the >> default value based on its type, and it will still be polled by the >> reporter but not recorded. To an end-user's experience it will mean = that >> for example the monitoring UI that displays all polled metrics will = still >> show the metrics graph, with the value consistently shown as the = default >> value, instead of not showing the graphs at all. >>=20 >> 3. Could you elaborate on the "shouldRecord()" function, e.g. which = class >> it will be added to? Does it contain any parameters? >>=20 >>=20 >> Guozhang >>=20 >>=20 >>=20 >> On Sun, Jan 1, 2017 at 5:31 AM, Eno Thereska >> wrote: >>=20 >>> Thanks for starting the discussion on these KIPs Aarti. >>>=20 >>> Eno >>>=20 >>> On Sunday, January 1, 2017, Aarti Gupta = wrote: >>>=20 >>>> Thanks Radai, >>>>=20 >>>> Yes that is the correct link, my bad >>>>=20 >>>>=20 >>>> https://cwiki.apache.org/confluence/display/KAFKA/KIP- >>>> 105%3A+Addition+of+Record+Level+for+Sensors >>>>=20 >>>>=20 >>>>=20 >>>> Aarti >>>>=20 >>>> On Sat, Dec 31, 2016 at 9:32 PM radai >>> > wrote: >>>>=20 >>>>> link leads to 104. i think this is the correct one - >>>>>=20 >>>>>=20 >>>>> https://cwiki.apache.org/confluence/display/KAFKA/KIP- >>>> 105%3A+Addition+of+Record+Level+for+Sensors >>>>>=20 >>>>> ? >>>>>=20 >>>>>=20 >>>>>=20 >>>>> On Fri, Dec 30, 2016 at 8:31 PM, Aarti Gupta = >>> > >>>>> wrote: >>>>>=20 >>>>>=20 >>>>>=20 >>>>>> Hi all, >>>>>=20 >>>>>>=20 >>>>>=20 >>>>>> I would like to start the discussion on KIP-105: Addition of = Record >>>> Level >>>>>=20 >>>>>> for Sensors >>>>>=20 >>>>>> *https://cwiki.apache.org/confluence/pages/viewpage.action? >>>>>=20 >>>>>> < >>>>> https://cwiki.apache.org/confluence/pages/viewpage. >>>> action?pageId=3D67636480 >>>>>=20 >>>>>>> * >>>>>=20 >>>>>> *pageId=3D67636483* >>>>>=20 >>>>>>=20 >>>>>=20 >>>>>> Looking forward to your feedback. >>>>>=20 >>>>>>=20 >>>>>=20 >>>>>> Thanks, >>>>>=20 >>>>>> Aarti and Eno >>>>>=20 >>>>>>=20 >>>>>=20 >>>>>=20 >>>>=20 >>>=20 >>=20 >>=20 >>=20 >> -- >> -- Guozhang >>=20