Spring Kafka生产者是否会返回无效偏移量且不抛异常？偏移量检查是否必要？

我正在重写KafkaTemplate实现同步发送方法，代码如下：

public class SyncKafkaTemplate<K, V> extends KafkaTemplate<K, V> {

    public SyncKafkaTemplate(ProducerFactory<K, V> producerFactory) {
        super(producerFactory);
    }

    @Override
    public ListenableFuture<SendResult<K, V>> send(ProducerRecord<K, V> record) {
        ListenableFuture<SendResult<K, V>> future = super.send(record);

        try {
            SendResult<K, V> result = future.get();

            if (!result.getRecordMetadata().hasOffset()) {
                throw new RuntimeException("Produce request failed to return valid offset");
            }
        } catch (Exception ex) {
            throw new RuntimeException(ex);
        }

        return future;
    }
}

我有以下疑问：

• 此处的.hasOffset()检查是否是确保消息生产成功的必要操作？
• 当生产者未获得有效偏移量时，send请求是否总会抛出异常？
• 此前未添加该检查时，偶尔出现生产者无报错但消息未提交到服务器分区的丢失情况，添加检查后无法复现，不确定是否真正解决了问题。

问题解答 #

1. .hasOffset()检查的必要性 #

从Kafka生产者机制来看，当消息成功被Broker确认（取决于acks配置），Producer会收到包含有效偏移量的RecordMetadata。正常情况下，只要future.get()没有抛出异常，就意味着消息已被Broker持久化，此时hasOffset()必然返回true。

但存在极端罕见的边缘场景：比如Kafka客户端内部逻辑异常，导致上层未捕获到异常，但实际未正确获取偏移量。你的场景中添加检查后解决了丢消息问题，可能正好命中了这类情况。

2. 未获得有效偏移量时是否会抛出异常 #

默认配置下，当生产者无法获取有效偏移量（如Broker返回错误、网络异常、消息未被确认），future.get()一定会抛出对应异常：

• Broker返回错误（分区不可用、权限不足等）会抛出KafkaException；
• 请求超时（如request.timeout.ms过短）会抛出TimeoutException；
• 序列化失败等客户端异常会直接在send调用时抛出，不会进入future.get()环节。

但如果配置了acks=0，生产者不会等待Broker确认，future.get()会立即返回，但RecordMetadata中的偏移量为-1，hasOffset()返回false。这种场景下，消息是否成功完全依赖客户端发送，Broker可能未收到消息，此时hasOffset()检查就非常必要。

3. 丢消息问题的验证 #

你之前遇到的无报错丢消息，大概率是因为使用了acks=0配置：此时生产者不等待Broker确认，future.get()不会抛出异常，但消息可能因网络波动等原因未到达Broker。添加hasOffset()检查后，会在这种场景下抛出异常，避免“无报错但丢消息”的情况。

如果生产者配置是acks=1或acks=all，理论上future.get()成功就代表消息已被Broker确认，hasOffset()检查属于冗余，但也不会产生副作用。如果之前的丢消息确实因偏移量异常导致，保留检查可作为额外防御手段。

建议你检查生产者的acks配置：

• 若为acks=0，必须保留hasOffset()检查，或改为更高的acks级别；
• 若为acks=1或acks=all，可去掉检查，也可保留作为兜底验证。

内容的提问来源于stack exchange，提问作者Oak