acks: -1 时消费代码如何写

`acks: -1` 是Kafka消息确认机制中的一个设置，它表示消费者不向生产者发送确认信息。当acks 设置为-1时，通常适用于以下场景：

1. 高吞吐量场景：如果消费者不需要持久化消息处理结果，例如实时流处理或数据清洗，可以使用 `acks=-1` 来提高性能。

2. 分布式系统：在某些分布式消费环境中，消费者可能有自己的事务管理，并不依赖于Kafka的消息确认。在这种情况下，不需要对每个消息发送确认。

在编写使用 `-1` 确认的消费者代码时，通常会像下面这样配置：

Properties props = new Properties();
props.put("bootstrap.servers", "your-bootstrap-server:9092");
props.put("group.id", "your-consumer-group");
props.put("enable.auto.commit", "false"); // 自动提交被关闭，手动控制确认
props.put("acks", "all"); // 尽管acks设为-1，这里为了明确指定确认策略，这里通常写成"all"

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("your-topic"));

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
    
    for (ConsumerRecord<String, String> record : records) {
        processMessage(record); // 消费并处理消息

        // 如果需要手动控制确认，可以在这里调用acknowledge()方法
        // record.acknowledge();
    }
}

在这个例子中，你需要手动调用 `record.acknowledge()` 方法来确认消费过消息，因为 `acks=-1` 表示不自动发送确认。