Kafka生产者禁用问题

1. 在代码中设置acks为0，即异步发送消息，不等待确认。这可以提高生产者的吞吐量，并减少生产者发送消息时的延迟。示例代码如下：

Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("acks", "0"); props.put("retries", 0); props.put("batch.size", 16384); props.put("linger.ms", 1); props.put("buffer.memory", 33554432); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); Producer<String, String> producer = new KafkaProducer<String, String>(props);

2. 另一种解决方法是使用Kafka生产者配置中的max-in-flight-requests-per-connection参数来限制生产者发送的消息数。这样可以避免生产者发送过多消息导致通信失败的问题。代码示例如下：

Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("acks", "1"); props.put("retries", 0); props.put("batch.size", 16384); props.put("linger.ms", 1); props.put("buffer.memory", 33554432); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("max.in.flight.requests.per.connection", 5); Producer<String, String> producer = new KafkaProducer<String, String>(props);

注意：如果您使用的是Kafka版本低于0.11，则max.in.flight.requests.per.connection参数应为max.in.flight.requests。