大数据学习笔记（17_1）

第17章 KAFKA 生产者与消费者实例

17.1 生产者实例

采用Java客户端开发一个用于消息发布与订阅的应用系统。Kafka生产者客户端由以下API构成。

17.1.1KafkaProducer API

KafkaProducerAPI的主要构成单元为"KafkaProducer"类。该类具备连接kafka中间件的功能，其内部包含若干具体方法。

KafkaProducer类中包含用于异步向Topic发送数据的send方法。send()方法具有以下特性：

    producer.send(new ProducerRecord<byte[],byte[]>(topic, partition, key1, value1) , callback);
    
    
    plain

ProducerRecord： 生产者用于管理待发送记录的缓存结构。

Callback： 当服务器确认记录接收后，可执行用户自定义的回调操作（若为null则表示不执行回调）。****

KafkaProducer类中包含flush方法，其作用是保证此前所有消息已真正完成传输。该方法的具体调用格式如下：

    public void flush()
    
    plain

KafkaP