java - 使用 KafkaProducer 发送恰好一个 ProducerRecord

Question

使用什么配置可以只使用 KafkaProducer 发送一个 ProducerRecord 以避免批量发送消息？

或者不可能使用 KafkaProducer 只发送一条记录？

(使用 Kafka Streams 可以仅处理一条记录并将其发送到某个主题)。

我当前的配置是:

  Properties kafkaProps = new Properties();
  kafkaProps.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
  kafkaProps.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
  kafkaProps.put(ProducerConfig.ACKS_CONFIG, "1");
  kafkaProps.put("retries", 3);
  kafkaProps.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG, 120000);
  kafkaProps.put(ProducerConfig.BATCH_SIZE_CONFIG, 1024);
  kafkaProps.put(ProducerConfig.LINGER_MS_CONFIG, 0);
  kafkaProps.put(ProducerConfig.BUFFER_MEMORY_CONFIG, 1024);
  kafkaProps.put("compression.type", "gzip");
  KafkaProducer producer = new KafkaProducer<String, String>(kafkaProps);

Answer 1

您可以在发送之后立即显式刷新生产者