Re: acks this category properties in Which *.java Defined???

2020-04-02 Thread James Olsen
org.apache.kafka.clients.producer.ProducerConfig org.apache.kafka.clients.consumer.ConsumerConfig > On 3/04/2020, at 04:30, 一直以来 <279377...@qq.com> wrote: > > Properties props = new Properties(); props.put("bootstrap.servers", > "localhost:9092"); props.put("acks", "all");

acks this category properties in Which *.java Defined???

2020-04-02 Thread ????????
Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("acks", "all"); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");