Re: Migrating from kafka08 client to kafka010
Short answer is it isn't necessary. Long answer is that you aren't just changing from 08 to 10, you're changing from the receiver based implementation to the direct stream. Read these: https://github.com/koeninger/kafka-exactly-once
Migrating from kafka08 client to kafka010
Hi All, Recently I started migrating the code from kafka08 to kafka010. in 08 *topics * argument takes care of consuming number of partitions for each topic. def createStream( ssc: StreamingContext, zkQuorum: String, groupId: String, topics: Map[String, Int],