samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stefano Rebora <stere...@live.it>
Subject Newbie to samza - Quick Start doubts
Date Fri, 03 May 2019 07:44:25 GMT
Hello,

I'm a newbie to samza and I need to clear some doubts.
I've followed the Wordcount Samza Quick Start Tutorial (http://samza.apache.org/startup/quick-start/latest/samza.html)
and I've the following questions:

1) I've noticed that the scripts provided install an old version of Kafka broker (0.10.1.1)
and the samza app uses an old kafka client (0.11.0.2). Why? I've not found any info about
the kafka version required. Does samza support newer versions of kafka?

2) I run the application as suggested in the tutorial:

./gradlew run --args="--config-factory=org.apache.samza.config.factories.PropertiesConfigFactory
--config-path=file://$BASE_DIR/src/main/config/word-count.properties"

The app works correctly but does not terminate.
I'v set also a timeout, for example:

runner.waitForFinish(Duration.ofSeconds(30));

but it seems to be ignored. Am I doing something wrong? What is the correct way to terminate
the execution?

Thanks in advance.

Stefano



Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message