async def METHOD_NAME(self) -> None:
    app = self.app
    topic = app.topic(self.topic_name, value_serializer=self.value_serializer)
    create_agent = app.agent(
        topic,
        concurrency=self.concurrency,
        isolated_partitions=self.isolated_partitions,
    )
    self.agent = create_agent(self.process)
    assert self.agent