async def METHOD_NAME(*, app, logging):
    await AgentIsolatedRebalanceCase.run_test(
        app=app,
        num_messages=100,
        concurrency=1,
        partitions=[0, 1, 2, 3],
        reassign_partitions={
            10: [0],
            20: [1],
            30: [0, 1],
            40: [2, 3],
            50: [0, 1, 2, 3],
            60: [4, 5, 6, 7],
        },
        isolated_partitions=True,
    )