All, I think it's great that the ProcessorContext offers the partition and offset of the current record being processed; however, it offers no way for me to actually use the information. I would like to be able to rewind to a particular offset on a partition if I needed to. The consumer is also not exposed to me so I couldn't access things directly that way either. Is this in the works or would it interfere with rebalancing/auto-commits? Mike
- KStreams Rewind Offset Michael D. Coon
- Re: KStreams Rewind Offset Matthias J. Sax
- Re: KStreams Rewind Offset Michael D. Coon
- Re: KStreams Rewind Offset Guozhang Wang