Kafka是一個分布式的消息隊列系統，它提供了多種方式來判斷消息是否發送成功。下面是幾種常用的方法：

1. 同步發送方式：使用Producer的send()方法發送消息，并使用返回的Future對象的get()方法進行阻塞等待，如果get()方法能夠正常返回則說明消息發送成功，否則發送失敗。

ProducerRecord<String, String> record = new ProducerRecord<>("topic", "key", "value");
try {
    RecordMetadata metadata = producer.send(record).get();
    System.out.println("消息發送成功，offset：" + metadata.offset());
} catch (InterruptedException | ExecutionException e) {
    System.err.println("消息發送失敗：" + e.getMessage());
}

2. 異步發送方式：使用Producer的send()方法發送消息，并傳入一個Callback對象，該對象在消息發送成功或失敗時會被調用。

ProducerRecord<String, String> record = new ProducerRecord<>("topic", "key", "value");
producer.send(record, new Callback() {
    @Override
    public void onCompletion(RecordMetadata metadata, Exception exception) {
        if (exception == null) {
            System.out.println("消息發送成功，offset：" + metadata.offset());
        } else {
            System.err.println("消息發送失敗：" + exception.getMessage());
        }
    }
});

3. 消息發送確認機制：Kafka提供了消息發送確認機制，可以確保消息被成功發送到指定的分區并寫入磁盤。在Producer的配置中設置"acks"參數來指定確認機制的級別：

• acks=0：生產者在發送消息之前不會等待任何確認。
• acks=1：生產者在leader副本收到消息后會得到一個確認，不等待其他副本的確認。
• acks=all/-1：生產者在所有參與復制的副本都收到消息并確認后才會得到一個確認。

使用確認機制可以在一定程度上保證消息發送的可靠性。但需要注意的是，確認機制會增加消息發送的延遲，因此在性能要求較高的場景下可以考慮使用acks=1的級別。

無論使用哪種方式，都可以通過檢查返回的RecordMetadata對象中的offset值來判斷消息是否發送成功。如果offset不為-1，則表示消息發送成功，否則發送失敗。同時，還可以根據異常信息來判斷發送失敗的原因。