From users-return-37519-apmail-kafka-users-archive=kafka.apache.org@kafka.apache.org Wed Jun 5 23:45:25 2019 Return-Path: X-Original-To: apmail-kafka-users-archive@www.apache.org Delivered-To: apmail-kafka-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by minotaur.apache.org (Postfix) with SMTP id D75D419B46 for ; Wed, 5 Jun 2019 23:45:24 +0000 (UTC) Received: (qmail 67391 invoked by uid 500); 5 Jun 2019 23:45:10 -0000 Delivered-To: apmail-kafka-users-archive@kafka.apache.org Received: (qmail 67335 invoked by uid 500); 5 Jun 2019 23:45:10 -0000 Mailing-List: contact users-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@kafka.apache.org Delivered-To: mailing list users@kafka.apache.org Received: (qmail 67322 invoked by uid 99); 5 Jun 2019 23:45:09 -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; Wed, 05 Jun 2019 23:45:09 +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 05906C65D1 for ; Wed, 5 Jun 2019 23:45:09 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.162 X-Spam-Level: * X-Spam-Status: No, score=1.162 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, DKIM_VALID_EF=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-0.638, SPF_HELO_NONE=0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.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 fAOpmp1gw-ES for ; Wed, 5 Jun 2019 23:45:07 +0000 (UTC) Received: from mail-ot1-f45.google.com (mail-ot1-f45.google.com [209.85.210.45]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 655F25F1B9 for ; Wed, 5 Jun 2019 23:45:06 +0000 (UTC) Received: by mail-ot1-f45.google.com with SMTP id r10so284245otd.4 for ; Wed, 05 Jun 2019 16:45:06 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:references:in-reply-to:from:date:message-id:subject:to; bh=XzJkgk/dJTJCVDtab2yo6pOgp7B2VGPUeNVe9WzOPbQ=; b=DS+/QkwChEauZQKPYDRbQX6zl+kE8fipr1Qj2yLFjRQU5LFWxbEiUVvgJUOOtkFEwl BNzMjKJvOLjCoKKzSlGakqb9/nckM6ZOvZERZMm+dDBo1yfG3RyDOeKUXvE/a0sahK4E dI3w/1sFLBVN1t2WSQqIsvgAuDz3KNQbeFGM7zZ8MDbCDVD6mltgihknecGzAtH7fxe2 NNrwYnQz6hlnYvWcmmIdccXu6zXdmDO7rzHWXOCoiB2iyCA8lRlNnDU49jt3/wge9uEG KS0mFSfWRfmfAP1EVbfMLwom0JFu8lj8MdGIV4ldt3C24GZrHgHt9uZe8s4sNOC1jTxh NDxA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:references:in-reply-to:from:date :message-id:subject:to; bh=XzJkgk/dJTJCVDtab2yo6pOgp7B2VGPUeNVe9WzOPbQ=; b=HELef9yPbA8iBdmMIQRmx7LN7FskJEreQVoB880SQVxxj58Rz70V4sZWLFp68aXcez GNYk3J5jVriv+PJl/smZR3XTARJK1L+CZIV0ezJxEmwqbUBfE2Oxe/vVyDkeYY97yv/O iDT3dxAV0wZgW8maqELJZ9B3+lmu4nwy7+Q2Z3pNWO8UqAmma8kD2MwWMYb3c4j46S5y KD6TGf28/UDHOT5CwiSWPv5hIPFOp2UeqTCHc5wkR7/uo2IfVx8tRmPzHaMaOrK3x+T+ oM+prslQE85v+yyV6T8UsGVbUNaqYAJbOcuTCl5XY/xozECe6BgaDJtt51zXvqmZfZ8s kJyA== X-Gm-Message-State: APjAAAX33P1SeIUtDsmzeNxva0o64BP8P8/XcEgo18RU5a2jiPL4u4gz PI0gSUWrafJirbgpNNph8c4h6xVgcLo5/GiNTPvlXS7Rtag= X-Google-Smtp-Source: APXvYqwbz+BrDv8VkBiJRcV0pyYuP4zrXXzgoNnMn2O8QYSzfC22lrpDdJIP2BoutqIMVf1zL7YbmVOjiXum1IhThrk= X-Received: by 2002:a05:6830:146:: with SMTP id j6mr11594981otp.249.1559778304495; Wed, 05 Jun 2019 16:45:04 -0700 (PDT) MIME-Version: 1.0 References: In-Reply-To: From: Guozhang Wang Date: Wed, 5 Jun 2019 16:44:53 -0700 Message-ID: Subject: Re: Streams reprocessing whole topic when deployed but not locally To: users@kafka.apache.org Content-Type: multipart/alternative; boundary="000000000000c49561058a9c2f38" --000000000000c49561058a9c2f38 Content-Type: text/plain; charset="UTF-8" Hello Alessandro, What did you do for `restarting the app online`? I'm not sure I follow the difference between "restart the streams app" and "restart the app online" from your description. Guozhang On Wed, Jun 5, 2019 at 10:42 AM Alessandro Tagliapietra < tagliapietra.alessandro@gmail.com> wrote: > > Hello everyone, > > I've a small streams app, the configuration and part of the code I'm using > can be found here > https://gist.github.com/alex88/6b7b31c2b008817a24f63246557099bc > There's also the log when the app is started locally and when the app is > started on our servers connecting to the confluent cloud kafka broker. > > The problem is that locally everything is working properly, if I restart > the streams app it just continues where it left, if I restart the app > online it reprocesses the whole topic. > > That shouldn't happen right? > > Thanks in advance > > -- > Alessandro Tagliapietra -- -- Guozhang --000000000000c49561058a9c2f38--