Closed chunaiarun closed 7 months ago
I am looking for an option for doing commit for a single partition and offset
what I see is the third argument of the .kfx.CommitOffsets is a dictionary of partitions and offsets
No issues I will pass the dictionary with single partition and offset
I am looking for an option for doing commit for a single partition and offset
what I see is the third argument of the .kfx.CommitOffsets is a dictionary of partitions and offsets