[
https://issues.apache.org/jira/browse/GEARPUMP-122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15303684#comment-15303684
]
ASF GitHub Bot commented on GEARPUMP-122:
-----------------------------------------
Github user huafengw commented on a diff in the pull request:
https://github.com/apache/incubator-gearpump/pull/25#discussion_r64865492
--- Diff:
examples/streaming/kafka/src/main/scala/org/apache/gearpump/streaming/examples/kafka/KafkaReadWrite.scala
---
@@ -60,14 +64,19 @@ object KafkaReadWrite extends AkkaApp with
ArgumentsParser {
val sinkTopic = config.getString("sinkTopic")
val appConfig = UserConfig.empty
- val offsetStorageFactory = new KafkaStorageFactory(zookeeperConnect,
brokerList)
- val source = new KafkaSource(sourceTopic, zookeeperConnect,
offsetStorageFactory)
+ val props = new Properties
+ props.put(KafkaConfig.ZOOKEEPER_CONNECT_CONFIG, zookeeperConnect)
+ props.put(KafkaConfig.BOOTSTRAP_SERVERS_CONFIG, brokerList)
+ props.put(KafkaConfig.CHECKPOINT_STORE_NAME_PREFIX_CONFIG, appName)
+ val source = new KafkaSource(sourceTopic, props)
+ val checkpointStoreFactory = new KafkaStoreFactory(props)
+ source.checkpoint(checkpointStoreFactory)
--- End diff --
What if user doesn't call ```checkpoint```?
> 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
> Fix For: 0.8.1
>
> 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。
> 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 without offset checkpoint, then messages begin
> to flow.
> "screenshot-1.png" means app started for 7 minutes and no messages received
> 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
> checkpoint.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
