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 2BE1B2009E8 for ; Mon, 30 May 2016 13:46:01 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 2A782160A19; Mon, 30 May 2016 11:46:01 +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 73696160A16 for ; Mon, 30 May 2016 13:46:00 +0200 (CEST) Received: (qmail 69220 invoked by uid 500); 30 May 2016 11:45:59 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 69210 invoked by uid 99); 30 May 2016 11:45:59 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 30 May 2016 11:45:59 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 01B88C0D9E for ; Mon, 30 May 2016 11:45:59 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.279 X-Spam-Level: * X-Spam-Status: No, score=1.279 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=soom-it-ch.20150623.gappssmtp.com Received: from mx2-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id EnKOlaPJ8KlU for ; Mon, 30 May 2016 11:45:56 +0000 (UTC) Received: from mail-wm0-f47.google.com (mail-wm0-f47.google.com [74.125.82.47]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with ESMTPS id 498E35F237 for ; Mon, 30 May 2016 11:45:56 +0000 (UTC) Received: by mail-wm0-f47.google.com with SMTP id z87so68142964wmh.0 for ; Mon, 30 May 2016 04:45:56 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=soom-it-ch.20150623.gappssmtp.com; s=20150623; h=from:subject:message-id:date:to:mime-version; bh=zn7OE+OKmez2kd/CNpdAQz2W6L4M4stDPTZ8+HkG2Jw=; b=tH66RQR75jU79dy42bIaS1Tiuphb9kH7qkBqevJCJkTsB6oMQKYzw61ko5so9B0cJU bswArp5/wSWHx4BPGZ3If3nrgmU8duJDWu02mfAn1JCW/JQJY2M7TkftmOeindlpI+1n okf2lkKvfEyh+ftFIXoBlZJ9UDa3QjmFJrdsOYq5x0kUBDr3V+JcJ4UikyRmDegU5Q5I hAmfmblHjUv+hI4q3S1cvkQkzkV1JSNAZGffOjWLZikbgEwQMVgTnueynWXuIf98IHsJ NTHQDxzlDKH8UZz5WkpXxSK6pDEc5xfIGOaOOLfqI4DRYcrqqKKPzMcqnH47D4tDViex TMSQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:from:subject:message-id:date:to:mime-version; bh=zn7OE+OKmez2kd/CNpdAQz2W6L4M4stDPTZ8+HkG2Jw=; b=dCx9+LQHN1O8RHWtxyKiGVgm1JgnpU+XaODc5NdaBqfOG+AgCYvDvHv5G7JZH378NK Czn3oufpgtAUAcw/Nemcr1q2336CImzwVCMAHeZ45NgBhLOB0jC+fcoA02oXPb92Dscx OCEcaZNnv63UraLGYqFRBOKdtmjfwaWyZZvN/1h29Zqy4VwzR6WmQk2yq7sOMNUxRmM6 n+TsqZ2PhhJqGST4fUtDjZznbfyMTkHjRR7oBKU+PUpvrSXZgnPPLLLxOrpLD3Bp26+3 Ok/4OgqlY+XXVtA2ZWh0gFJZky1AQ1IzPiHrYRW5kCKYGmXhX31KUVvXr/lacb4pKU/Z yrBQ== X-Gm-Message-State: ALyK8tJblap95T9vi7pFmA4HYKeKm8q5Au3qDFzYCVkHUMENIZ/vfnK/68Zz11KyUX6ZM1/C X-Received: by 10.28.128.67 with SMTP id b64mr11065961wmd.2.1464608755999; Mon, 30 May 2016 04:45:55 -0700 (PDT) Received: from [192.168.0.57] (164.10.24.31.ftth.as8758.net. [31.24.10.164]) by smtp.gmail.com with ESMTPSA id cz3sm34106714wjb.14.2016.05.30.04.45.55 for (version=TLS1 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Mon, 30 May 2016 04:45:55 -0700 (PDT) From: simon peyer Content-Type: multipart/alternative; boundary="Apple-Mail=_ABE470D3-571A-4964-8C0A-91AD1E977D04" Subject: Flink Kafka from Time Offset Message-Id: <7E222254-EB60-4FF4-B9E2-CBF965F69211@soom-it.ch> Date: Mon, 30 May 2016 13:45:54 +0200 To: user@flink.apache.org Mime-Version: 1.0 (Mac OS X Mail 9.2 \(3112\)) X-Mailer: Apple Mail (2.3112) archived-at: Mon, 30 May 2016 11:46:01 -0000 --Apple-Mail=_ABE470D3-571A-4964-8C0A-91AD1E977D04 Content-Transfer-Encoding: quoted-printable Content-Type: text/plain; charset=us-ascii Hi together I'm using flink 1.0.1 and a FlinkKafkaConsumer09. I'm very interested in getting data from a specific Time offset in = Kafka. Is there a property which can do this? Or is there another way of handling such issues? I'm also using checkpointing. If I deploy a new pipeline with the same id's on the nodes, will the = checkpoint be atomatically loaded and the state restored? -Thanks Simon= --Apple-Mail=_ABE470D3-571A-4964-8C0A-91AD1E977D04 Content-Transfer-Encoding: quoted-printable Content-Type: text/html; charset=us-ascii Hi together

I'm using flink 1.0.1 and a FlinkKafkaConsumer09.
I'm = very interested in getting data from a specific Time offset in = Kafka.

Is there a property which can do = this?
Or is there = another way of handling such issues?

I'm also using checkpointing.
If I deploy a new pipeline with the same id's on the = nodes, will the checkpoint be atomatically loaded and the state = restored?

-Thanks
Simon
= --Apple-Mail=_ABE470D3-571A-4964-8C0A-91AD1E977D04--