Re: In Spark streaming, will saved kafka offsets become invalid if I change the number of partitions in a kafka topic?
Please help! On Sat, Feb 25, 2017 at 11:10 PM, shyla deshpandewrote: > I am commiting offsets to Kafka after my output has been stored, using the > commitAsync API. > > My question is if I increase/decrease the number of kafka partitions, will > the saved offsets will
In Spark streaming, will saved kafka offsets become invalid if I change the number of partitions in a kafka topic?
I am commiting offsets to Kafka after my output has been stored, using the commitAsync API. My question is if I increase/decrease the number of kafka partitions, will the saved offsets will become invalid. Thanks