kafka-ConnectionError in test about faust HOT 1 CLOSED

@mark.asyncio()
async def test_consumer_agent(
    test_app, mocker, stream_key, stream_value, expected_event
):
    """Testing agent consuming events from topic source_topic and sending to topic target_topic"""

    mocker.patch(
        "workers.consumer.target_topic.send",
        return_value=expected_event,
    )

    async with consumer.test_context() as agent:
        event = await agent.put(key=stream_key, value=stream_value)
        assert agent.results[event.message.offset] == expected_event