一、clients模块的目录结构
src/main/java/org.apache.kafka目录
clients - 生产者、消费者以及其他客户端附属功能
common - 公共类
server.policy - 策略封装类
二、生产者
2.1 KafkaProducer
2.1.1 继承关系
2.1.2 使用方法
扫描二维码关注公众号,回复:
8646863 查看本文章
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("acks", "all");
props.put("retries", 0);
props.put("batch.size", 16384);
props.put("linger.ms", 1);
props.put("buffer.memory", 33554432);
props.put("key.serializer", "org.ap