Kafka - Manufacturer Confirmation

Question

In the video tutorial, I saw that Kafka Broker supports 3 types of confirmation when the manufacturer sends a message.

0 - Fire and Forget 1 - Ack Leader 2 - Ack of all brokers

I am using the Kafka Java API to post a post. Is this something that needs to be set for each broker using server.properties specific to each broker, or is it something that should be set by the manufacturer? If it must be installed by the manufacturer, explain how it can be installed using the Java API.

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.RecordMetadata;

import java.util.Properties;

public class KafkaProducerApp {

    public static void main(String[] args){
        Properties properties = new Properties();
        properties.put("bootstrap.servers","localhost:9092,localhost:9093,localhost:9094");
        properties.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
        properties.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");

        KafkaProducer<String,String> kafkaProducer = new KafkaProducer<String, String>(properties);

        try{
            for(int i=0;i<150;i++) {
                RecordMetadata ack = kafkaProducer.send(new ProducerRecord<String, String>("replicated_topic", Integer.toString(i), "MyMessage" + Integer.toString(i))).get();
                System.out.println(" Offset = " + ack.offset());
                System.out.println(" Partition = " + ack.partition());
            }
        } catch (Exception ex){
            ex.printStackTrace();
        } finally {
            kafkaProducer.close();
        }



    }

}

Answer 1

This is a property of the manufacturer and is set similar to other properties that you have in your code:

properties.put("acks","all");

.

, ( ) min.insync.replicas, .