kafka-streaming偏移量管理

文章目錄 RuozeKafkaProducer.java 用checkpoint記錄偏移量 用mysql記錄偏移量 MysqlOffsetApp RuozeKafkaProducer.java 先寫一個kafka製造數據的東東 package com.ruozedata.bigdata.kafka; import kafka.javaapi.producer.Producer; import

>>阅读原文<<