馬老師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());
標簽：
