Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 24BD11811F for ; Thu, 4 Feb 2016 20:22:54 +0000 (UTC) Received: (qmail 49185 invoked by uid 500); 4 Feb 2016 20:22:41 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 49107 invoked by uid 500); 4 Feb 2016 20:22:41 -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 49097 invoked by uid 99); 4 Feb 2016 20:22:41 -0000 Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 04 Feb 2016 20:22:41 +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 CE78EC0BE4 for ; Thu, 4 Feb 2016 20:22:40 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.198 X-Spam-Level: * X-Spam-Status: No, score=1.198 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_LOW=-0.7, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id hXXha3-7Cb0f for ; Thu, 4 Feb 2016 20:22:40 +0000 (UTC) Received: from mail-io0-f174.google.com (mail-io0-f174.google.com [209.85.223.174]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with ESMTPS id ED3A442BC5 for ; Thu, 4 Feb 2016 20:22:39 +0000 (UTC) Received: by mail-io0-f174.google.com with SMTP id g73so106230235ioe.3 for ; Thu, 04 Feb 2016 12:22:39 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=esLA1zmWOr3EOEO+yAt0Iwwsb/P2GVpBYGHRAtU+nU0=; b=zm1y5vs/8J9gvn+qw0EAjhiMjPltyDu1ybxusp8QxKEwqpa07diD+qmHOo8DKkbmNI 7xGZVQaKO76y1M1+olY/3C26EwkiXwDXjpbx22YIzLGD1Fv3hOCuGDqKNYd9CwTn5R82 n6xJr8PZqZ38bKBknT322dLuXP8zXAT1uhF7+ScPA3C6ctr5lQWQ7Gpgvv0cuGH46fwx gZKpfoMFGoVzhsb3cFglAK6OAxcjwcM+iCmGiJwvK8Zn892A7kD4i5xEkmwj6GrHJTBk y3V7JGxnWcyKYbFzuMG5ld9QIEkYZ3vnQjt6LHtWgrLczXmrfWMgVUuX7YP3+0R8QB7a UeGA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:date:message-id:subject:from:to :content-type; bh=esLA1zmWOr3EOEO+yAt0Iwwsb/P2GVpBYGHRAtU+nU0=; b=flqbhtbvxvxP0PjiMbW3GKMPMtb++Df70zl/iw/uzbo4SWmm8VnsTnZPMszebVsnTk 8wS8+o+iGNah7V+hG32+y0kNFXYPZc8iTZEGijFyjaih9cPZmiGRvHWhGVU1Lot2Lhmg FbLJUBJyvkBgwtMYzlQTWrkbeVqTvNgmCo3ZAcYIrMHf7sb/dPhHGL8wA+cLdD9kGdpy AP08VdPHNAJVW4maHxqtEkqsSIWC48ZY1Ud5XEgqUehSU0W1zlkwbpL2ND5YNE/mhLCJ Ep+EmcS9rRTi1TPlDyNJxTSk0FWhNWjzKAWlgTmaFFu3Q8KIbcJRK6JHmZZ7g+AeS7qO QdeQ== X-Gm-Message-State: AG10YOT05k27ZI4/Mep7+1N19PaSlVso0NgEx1+a72APC6/62GV2SuHN6F6bA9wBZKKTT7yDKipplsmWwiLoqw== MIME-Version: 1.0 X-Received: by 10.107.33.14 with SMTP id h14mr10146974ioh.108.1454617359576; Thu, 04 Feb 2016 12:22:39 -0800 (PST) Received: by 10.107.26.139 with HTTP; Thu, 4 Feb 2016 12:22:39 -0800 (PST) Date: Thu, 4 Feb 2016 15:22:39 -0500 Message-ID: Subject: Flink_Kafka From: Vinaya M S To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a1141a3dc00773d052af77fc2 --001a1141a3dc00773d052af77fc2 Content-Type: text/plain; charset=UTF-8 Hi, I'm new to Flink. I was working with Flink and Kafka before. It was working fine. But now Flink is not able to consume data from Kafka even with newly created topic. This is the log: 15:12:59,684 INFO org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer - No prior offsets found for some partitions in topic KafkaTweet. Fetched the following start offsets [FetchPartition {partition=0, offset=3061}] I'm using Flink: 0.10.1 and Kafka:8.2.2 and flink-connector-kafka 10.1. *Any help would be much appreciated.* *Thank you,* *Vinaya* --001a1141a3dc00773d052af77fc2 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi,

I'm new to Flink. I was working= with Flink and Kafka before. It was working fine.
But now Flink = is not able to consume data from Kafka even with newly created topic.

This is the log:


15:12:59,684 INFO=C2=A0 org.apache.flink.streaming.connectors.kafka.Flink= KafkaConsumer=C2=A0 - No prior offsets found for some partitions in topic K= afkaTweet. Fetched the following start offsets [FetchPartition {partition= =3D0, offset=3D3061}]



I'm using Flink: 0.10.1 = and Kafka:8.2.2 and=C2=A0flink-connector-kafka 10.1.=



Any = help would be much appreciated.

<= u>

Thank you,

<= span style=3D"font-size:11px">Vinaya

--001a1141a3dc00773d052af77fc2--