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");
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");