I'm trying to run some very simple examples with kafka and running into a
strange problem.
I've documented this in detail in
https://issues.apache.org/jira/browse/KAFKA-12594#. The linked repo -
https://github.com/jamii/streaming-consistency/tree/main/kafka-streams - should
be runnable on any
Hi Mazen,
This sounds like a good use case. If you’d like, you can start a KIP to add an
enforceRebalance() method to the admin client interface. Feel free to ask here
for any guidance on the KIP process itself.
Regarding your usage, you will actually have to call poll(). That is the point
at
