Kafka生产者/消费者在每秒API调用中崩溃

1. 检查配置：检查Kafka生产者/消费者的配置文件是否正确。确保每个字段都匹配，并尝试增加一些连接超时时间和重试次数。

2. 减少批量大小：如果生产者的消息批量大小很大，在短时间内并发发送，容易导致连接超时和崩溃。因此，可以尝试减少批量大小或将消息调度到较长时间的窗口中。

3. 定时重启：生产者/消费者长时间运行，可能会导致一些连接泄漏或负荷不均衡，这些问题可能会在定期重启后得到解决。

示例代码：

producer = KafkaProducer(bootstrap_servers='localhost:9092', value_serializer=lambda m: json.dumps(m).encode('ascii'), request_timeout_ms=5000, max_block_ms=10000, batch_size=200, linger_ms=1000)

consumer = KafkaConsumer('test-topic', bootstrap_servers=['localhost:9092'], value_deserializer=lambda m: json.loads(m.decode('ascii')), auto_offset_reset='earliest', enable_auto_commit=True, request_timeout_ms=5000, max_poll_records=200, heartbeat_interval_ms=3000, session_timeout_ms=10000)