refactor: Handling der Partitionen in WordcountRebalanceListener