ZooKeeper清除已有的消费的offsets


CDH集群中的ZooKeeper

启动ZooKeeper客户端
zookeeper-client

清除消费者

例如
rmr /consumers/WarningStreamingTask/offsets


文章作者: 谢舟
版权声明: 本博客所有文章除特別声明外,均采用 CC BY 4.0 许可协议。转载请注明来源 谢舟 !
 上一篇
Eureka服务注册中心启动 Eureka服务注册中心启动
nohup启动(nohup不间断运行) nohup java -cp /usr/chl/springcloud/eureka/xz_bigdata_springcloud_eureka-1.0-SNAPSHOT.jar com.hsiehc
2019-07-25
下一篇 
SparkStreaming+Kafka的两种模式Receiver模式和Direct模式 SparkStreaming+Kafka的两种模式Receiver模式和Direct模式
SparkStreming + Kafka Receiver模式理解 Receiver模式理解在SparkStreaming程序运行起来后,Executor中会有Receiver Tasks接收Kafka推送过来的数据。数据会被持久化,默认
2019-07-19
  目录