From ece01e6e83c174ee098d355052078e9bbf536267 Mon Sep 17 00:00:00 2001 From: Nikolay Date: Wed, 11 Nov 2020 14:57:07 +0300 Subject: [PATCH] MINOR: commit method doesn't exists for Consumer, but `commitSync` does. (#9585) Reviewers: Chia-Ping Tsai --- .../java/org/apache/kafka/clients/producer/KafkaProducer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java b/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java index a7e867e1063..22c2141de4a 100644 --- a/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java +++ b/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java @@ -1093,7 +1093,7 @@ public class KafkaProducer implements Producer { * for(ConsumerRecord record: consumer.poll(100)) * producer.send(new ProducerRecord("my-topic", record.key(), record.value()); * producer.flush(); - * consumer.commit(); + * consumer.commitSync(); * } * *