Ben Plommer
Ben Plommer
It looks like your code expects all partition streams in the map to terminate on a rebalance and be replaced with new streams in the new partitions map, whereas what...
Reopening as we should document this properly.
Seems like a good idea - I'll try and take a look soon.
I think we could add something about this to the scaladoc.
> Should `poll` & co. also be on this list? It is a very low-level functionality, but it seems to be required for certain usages, such as seeking to the...
Though on second thought, won't that take effect when polling next happens anyway assuming you already have a `consumer.stream` open?
> > Though on second thought, won't that take effect when polling next happens anyway assuming you already have a `consumer.stream` open? > > > > In my case I...
That sounds reasonable. Another option would be to have `consumer.stream` emit an empty chunk when polling returns nothing - would that address your use case? (I don't see why we...
> Would be a much easier solution imho (both in terms of implementing it in fs2-kafka as well as for the user). As far as I can see, returning empty...
I think this is a great idea. We could initially make it a private method and implement the other methods in terms of it, so we have time to iron...