kafka-streaming偏移量管理

文章目录 RuozeKafkaProducer.java 用checkpoint记录偏移量 用mysql记录偏移量 MysqlOffsetApp RuozeKafkaProducer.java 先写一个kafka制造数据的东东 package com.ruozedata.bigdata.kafka; import kafka.javaapi.producer.Producer; import

>>阅读原文<<