永恒七号 2018-10-19 10:01 采纳率: 30.8%
浏览 734

Storm-kafka集成问题,求解答

Read partition information from: /f-k-s/wordCount/partition_0 --> null
67357 [Thread-108-kafka_spout-executor[18 18]] INFO o.a.s.k.PartitionManager - No partition information found, using configuration to determine offset
67357 [Thread-108-kafka_spout-executor[18 18]] INFO o.a.s.k.PartitionManager - Starting Kafka 192.168.1.19 Partition{host=192.168.1.19:9092, topic=f-k-s, partition=0} from offset 4731080

本地模式启动!日志打印可以看到偏移量
但是zookeeper 客户端登录无法查看偏移量
如果在storm tuple里获取到偏移量值

  • 写回答

1条回答 默认 最新

  • zqbnqsdsmd 2018-10-27 12:41
    关注
    评论

报告相同问题?