解决org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for xxx topic

这个错误提示通常是由于Kafka生产者在发送消息时，等待Broker响应超时而导致的。可以尝试以下几种方法来解决这个问题：

1. 增加超时时间：在创建Kafka生产者时，可以设置`max.block.ms`属性来增加等待Broker响应的最大时间。例如：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("max.block.ms", "5000"); //设置等待时间为5秒
KafkaProducer<String, String> producer = new KafkaProducer<>(props, new StringSerializer(), new StringSerializer());

2. 减少消息发送频率：如果生产者连续发送大量消息，可能会导致Broker无法及时处理，从而导致超时异常。可以尝试减少消息的发送频率，例如增加发送消息之间的间隔时间。

3. 增加Broker处理能力：如果以上两种方法都无法解决问题，可以考虑增加Broker的处理能力，例如增加Broker节点、优化Broker配置等。