storm集群是1.0.0版本,kafka的集群版本是0.10.0,所以想当然的使用了kafka_2.10-0.10.0.1.jar作为storm-kafka-1.0.0.jar的依赖使用,

没想到导致topology无法启动,spout无法构建,报错“无法找到类InvalidTimestampException”,最终将kafka_2.10-0.10.0.1.jar替换为kafka_2.10-0.8.2.1.jar之后问题解决。

相关文章:

  • 2021-10-17
  • 2022-01-23
  • 2021-09-18
  • 2022-12-23
  • 2022-12-23
  • 2021-06-18
  • 2022-01-03
  • 2021-08-21
猜你喜欢
  • 2022-12-23
  • 2022-01-08
  • 2021-10-01
  • 2022-12-23
  • 2021-08-17
  • 2022-12-23
  • 2022-12-23
相关资源
相似解决方案