Kafka - Producer Acknowledgegment

Question

我在視頻教程中看到，當製作人發佈消息時，Kafka Broker支持3種類型的確認。

0 - 消防和忘記 1 - 領導確認 2 - 所有的經紀人

我使用卡夫卡的Java API發佈消息的確認。這是否必須爲每個代理使用每個代理特有的server.properties設置，還是必須由生產者設置？如果它必須由生產者設置，請解釋如何使用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

這是一個生產性和設置類似於你在你的代碼具有其它特性：

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

所有配置的生產屬性的列表可以發現here。

您可能還想看看與此生產者配置相關的經紀人（或主題）propertymin.insync.replicas。