我有一个api端点

def post():

    .....
    producer = KafkaProducer(bootstrap_servers=["some ip: port"],
                             value_serializer=lambda x: dumps(x).encode('utf-8'), 
                                compression_type='gzip')
    producer.send(topic,data)
    ....

此端点每10秒被许多客户端（超过10000个）命中一次。
此代码有时工作，有时失败，并出现“nobrokersavailable”错误。由于它有时工作，我假设我的Kafka混淆是正确的，它是有关的负荷。
我的kafka是一个单节点配置，主题是单分区的。
我能做些什么使我的端点能够处理这么多的负载。