Mailing-List: contact dev-help@gearpump.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@gearpump.incubator.apache.org
Date: Thu, 12 May 2016 02:32:12 +0000 (UTC)
From: "Qi Shu (JIRA)" <jira@apache.org>
To: dev@gearpump.incubator.apache.org
Message-ID: <JIRA.12967356.1462961018000.172354.1463020332871@Atlassian.JIRA>
In-Reply-To: <JIRA.12967356.1462961018000@Atlassian.JIRA>
References: <JIRA.12967356.1462961018000@Atlassian.JIRA> <JIRA.12967356.1462961018174@arcas>
Subject: [jira] [Updated] (GEARPUMP-122) KafkaSource Stuck
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable
archived-at: Thu, 12 May 2016 02:32:17 -0000


     [ https://issues.apache.org/jira/browse/GEARPUMP-122?page=3Dcom.atlass=
ian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Qi Shu updated GEARPUMP-122:
----------------------------
    Description:=20
Kafka's version is 2.10-0.8.2.0 and deployed on a cluster of 3 machines. Ge=
arpump's version is 2.11-0.8.0 and deployed on local mode.
The app running on gearpump is a java example Kafka2Kafka.
The topic has millions of messages in It=E3=80=82
After app started for a while, there were no messages received from kafka, =
but kafka console can recevie messages from that topic.
And if I use the kafka source withoud offset checkpoint, then messages begi=
n to flow.
"screenshot-1.png" means app started for 7 minutes  and no messages receive=
d from kafka source.
"2.png" was a screen shot of JProfiler, I use JProfiler to watch the thread=
 of Gearpump, and it seems the kafka source stucked when doing offset check=
point.


  was:
Kafka Version: 2.10-0.8.2.0
When Using KafkaSrouce, after app started for a while, there were no messag=
es received from kafka, but kafka console can recevie messages from that to=
pic.


> KafkaSource Stuck
> -----------------
>
>                 Key: GEARPUMP-122
>                 URL: https://issues.apache.org/jira/browse/GEARPUMP-122
>             Project: Apache Gearpump
>          Issue Type: Bug
>          Components: kafka
>    Affects Versions: 0.8.0
>            Reporter: Qi Shu
>            Assignee: Manu Zhang
>         Attachments: 2.png, screenshot-1.png
>
>
> Kafka's version is 2.10-0.8.2.0 and deployed on a cluster of 3 machines. =
Gearpump's version is 2.11-0.8.0 and deployed on local mode.
> The app running on gearpump is a java example Kafka2Kafka.
> The topic has millions of messages in It=E3=80=82
> After app started for a while, there were no messages received from kafka=
, but kafka console can recevie messages from that topic.
> And if I use the kafka source withoud offset checkpoint, then messages be=
gin to flow.
> "screenshot-1.png" means app started for 7 minutes  and no messages recei=
ved from kafka source.
> "2.png" was a screen shot of JProfiler, I use JProfiler to watch the thre=
ad of Gearpump, and it seems the kafka source stucked when doing offset che=
ckpoint.


--
This message was sent by Atlassian JIRA
(v6.3.4#6332)