public class KafkaConsumer<K,V> extends java.lang. ... StringDeserializer"); p rops.put("max.poll.records", 100); KafkaConsumer<String, String> consumer ...
確定! 回上一頁