Отправьте ровно одну запись производителя с KafkaProducer - PullRequest
0 голосов
/ 30 июня 2019

При какой конфигурации можно отправлять только один ProducerRecord с KafkaProducer, чтобы не отправлять сообщения партиями?

Или невозможно отправить только одну запись с 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);

1 Ответ

0 голосов
/ 01 июля 2019

Вы можете явно flush producer сразу после send

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...