Kafka提交间隔问题

在KafkaProducer中设置合适的批处理大小和延迟以提高消息发送效率。

示例代码：

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", "all");
props.put("batch.size", 16384); // 设置批处理大小
props.put("linger.ms", 1); // 设置延迟
props.put("buffer.memory", 33554432);

KafkaProducer<String, String> producer = new KafkaProducer<>(props);

在上述示例代码中，将批处理大小设置为16384字节，将延迟设置为1毫秒。这样可以在一定程度上提高消息发送效率，避免提交间隔问题。