kafka client依赖包和示例代码

【文件属性】：
文件名称：kafka client依赖包和示例代码
文件大小：6.09MB
文件格式：RAR
更新时间：2020-10-11 15:42:35
kafka,kafka client 版本：kafka_2.12-0.10.2.1，生产者消费者示例代码，以及client相关包。 部分代码： public static KafkaProducer getProducer() { if (kp == null) { Properties props = new Properties(); props.put("bootstrap.servers", "127.0.0.1:9092"); props.put("acks", "0"); props.put("retries", 0); props.put("batch.size", 16384); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); kp = new KafkaProducer(props); } return kp; }

【文件预览】：
kafka client
----scala-library-2.12.1.jar(5.03MB)
----testkafka.rar(4KB)
----slf4j-api-1.7.21.jar(40KB)
----slf4j-log4j12-1.7.21.jar(10KB)
----kafka-clients-0.10.2.1.jar(924KB)
----log4j-1.2.17.jar(478KB)
----scala-parser-combinators_2.12-1.0.4.jar(200KB)