Attempting to run a KStream app and seeing lots of this sort of error message:
> Resuming partition <topic>-# > Pausing partition <topic>-# > Not returning fetched records for assigned partition <topic>-# since it is no longer fetchable This cycles through all the partitions. It seems to get _some_ data from the topic but clearly it's struggling. I've tried restarting each broker in sequence and the logs aren't showing anything abnormal. Using **kafkacat** I can see that there is lots of data available.
