在Kafka中，生产者可以通过设置确认值（acks）来控制消息的持久性和可靠性。确认值可以设置为0、1或-1，分别代表以下含义：

• acks=0：生产者不会等待服务器的任何确认，直接将消息发送出去。这种情况下，生产者无法知道消息是否发送成功，也无法处理发送失败的情况。因此，该设置可能会导致消息丢失。
• acks=1：生产者在消息发送后会收到服务器的确认。这样可以确保消息已经成功到达服务器，但是无法保证消息已经被复制到所有的副本。如果副本在消息发送后立即发生故障，消息可能会丢失。
• acks=-1：生产者将等待消息在所有副本都被复制之后才会收到服务器的确认。这样可以确保消息的持久性和可靠性，但是会导致较高的延迟。

下面是一个使用Java语言的Kafka示例代码，展示了不同确认值下生产者的吞吐量：

import org.apache.kafka.clients.producer.*;

import java.util.Properties;
import java.util.concurrent.ExecutionException;

public class ProducerThroughputExample {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        String topicName = "test-topic";
        int numMessages = 10000;

        // Kafka producer configuration
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        // Create Kafka producer
        KafkaProducer producer = new KafkaProducer<>(props);

        // Send messages
        for (int i = 0; i < numMessages; i++) {
            ProducerRecord record = new ProducerRecord<>(topicName, Integer.toString(i), "Message " + i);
            producer.send(record).get();
        }

        // Flush and close the producer
        producer.flush();
        producer.close();

        System.out.println("All messages sent.");

    }
}

上述示例演示了如何使用Kafka的Java客户端库（kafka-clients）创建一个生产者，并向一个名为"test-topic"的主题发送10000条消息。在代码中，确认值默认为1，即每条消息发送后会收到服务器的确认。

如果需要将确认值设置为0或-1，只需要在producer配置属性中添加acks属性即可。例如，将确认值设置为0的代码示例如下：

// Kafka producer configuration
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("acks", "0");

// Create Kafka producer
KafkaProducer producer = new KafkaProducer<>(props);

将确认值设置为-1的代码示例如下：

// Kafka producer configuration
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("acks", "-1");

// Create Kafka producer
KafkaProducer producer = new KafkaProducer<>(props);

请注意，确认值的设置会影响生产者的吞吐量和延迟。acks=0的设置可能会导致消息丢失，acks=-1的设置可能会增加延迟。因此，在选择确认值时需要根据具体的应用需求进行权衡。