马老师Elasticsearch高手进阶篇

props.put("max.poll.records", 1000);    props.put("auto.offset.reset", "earliest");    props.put("key.deserializer", StringDeserializer.class.getName());    props.put("value.deserializer", StringDeserializer.class.getName());    props.put("key.serializer", StringSerializer.class.getName());    props.put("value.serializer", StringSerializer.class.getName());