Return-Path: X-Original-To: apmail-kafka-dev-archive@www.apache.org Delivered-To: apmail-kafka-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 74335EAB7 for ; Mon, 7 Jan 2013 09:46:16 +0000 (UTC) Received: (qmail 20809 invoked by uid 500); 7 Jan 2013 09:46:16 -0000 Delivered-To: apmail-kafka-dev-archive@kafka.apache.org Received: (qmail 20591 invoked by uid 500); 7 Jan 2013 09:46:16 -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 20105 invoked by uid 99); 7 Jan 2013 09:46:14 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 07 Jan 2013 09:46:14 +0000 Date: Mon, 7 Jan 2013 09:46:14 +0000 (UTC) From: "Maxime Brugidou (JIRA)" To: dev@kafka.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Updated] (KAFKA-685) ConsoleOffsetChecker does not work with 0.8 MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/KAFKA-685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maxime Brugidou updated KAFKA-685: ---------------------------------- Description: The ConsoleOffsetChecker does not work anymore with 0.8, this tool is very useful when used with the MirrorMaker. Here is a patch to make it work with some cosmetic changes: * script-friendly formatting (one line per partition) * offsets do not correspond to bytes anymore (so the lag is in number of messages, not GiB) * --broker-info optional option to print the broker list at the end (like the previous version) Example: {code} bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group KafkaMirror --zkconnect zoo.example.org:2181 Group Topic Pid Offset logSize Lag Owner KafkaMirror test 0 215385 215385 0 Some(KafkaMirror_broker01-1379350-71cf9117-0) KafkaMirror test 1 683564 683564 0 Some(KafkaMirror_broker03-1379351-71cf9117-0) KafkaMirror test2 0 176943 176943 0 Some(KafkaMirror_broker05-1379353-71cf91 {code} was: The ConsoleOffsetChecker does not work anymore with 0.8, this tool is very useful when used with the MirrorMaker. Here is a patch to make it work with some cosmetic changes: * script-friendly formatting (one line per partition) * offsets do not correspond to bytes anymore (so the lag is in number of messages, not GiB) * --broker-info optional option to print the broker list at the end (like the previous version) Example: {code:bash} bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group KafkaMirror --zkconnect zoo.example.org:2181 Group Topic Pid Offset logSize Lag Owner KafkaMirror test 0 215385 215385 0 Some(KafkaMirror_broker01-1379350-71cf9117-0) KafkaMirror test 1 683564 683564 0 Some(KafkaMirror_broker03-1379351-71cf9117-0) KafkaMirror test2 0 176943 176943 0 Some(KafkaMirror_broker05-1379353-71cf91 {code} > ConsoleOffsetChecker does not work with 0.8 > ------------------------------------------- > > Key: KAFKA-685 > URL: https://issues.apache.org/jira/browse/KAFKA-685 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.8 > Reporter: Maxime Brugidou > > The ConsoleOffsetChecker does not work anymore with 0.8, this tool is very useful when used with the MirrorMaker. > Here is a patch to make it work with some cosmetic changes: > * script-friendly formatting (one line per partition) > * offsets do not correspond to bytes anymore (so the lag is in number of messages, not GiB) > * --broker-info optional option to print the broker list at the end (like the previous version) > Example: > {code} > bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group KafkaMirror --zkconnect zoo.example.org:2181 > Group Topic Pid Offset logSize Lag Owner > KafkaMirror test 0 215385 215385 0 Some(KafkaMirror_broker01-1379350-71cf9117-0) > KafkaMirror test 1 683564 683564 0 Some(KafkaMirror_broker03-1379351-71cf9117-0) > KafkaMirror test2 0 176943 176943 0 Some(KafkaMirror_broker05-1379353-71cf91 > {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira