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
