SnappyData作业应用编程接口

Question

我们通过扩展SnappySqlJob并覆盖runSnappyJob和isValidJob创建了一个作业。

在runSnappyJob中，我们正在创建到Kafka的连接，以便每隔1秒轮询来自Kafka的消息。

使用以下命令终止作业后：

bin/snappy-job.sh stop  --lead lead:8090 --job-id <job_id>

我们可以在日志中看到，Kafka仍在轮询数据。

是否有API可以检查作业的运行状态，以便停止Kafka消费者？

Answer 1

不确定您注意到的这种行为，但是您应该使用SnappyStreamingJob而不是SnappyJob来管理流作业。

参见https://snappydatainc.github.io/snappydata/programming_guide/snappydata_jobs/ ...这里有一个指向示例的链接。