Hi,
Now I am using Samza 1.11.0 and Kafka 0.11.0.2, Java version is 1.8.
Everything is fine，but an error occurred when trying to get latest offset
information through checkpoint-tool.sh.
The exception stacks is below, and task.checkpoint.factory is actually
defined in configuration file.
Exception in thread "main" org.apache.samza.SamzaException: Configuration:
task.checkpoint.factory is not defined.
at org.apache.samza.checkpoint.CheckpointTool.run(CheckpointTool.scala:176)
at org.apache.samza.checkpoint.CheckpointTool$.main(CheckpointTool.scala:157)
at org.apache.samza.checkpoint.CheckpointTool.main(CheckpointTool.scala)
Can anyone help, thanks.
| |
ShuQi
|
|
[email protected]
|
签名由网易邮箱大师定制
