Kafka系列2:深入理解Kafka生产者( 四 )


ProducerRecord<String String> record = new ProducerRecord<>(topicName \"k\" + i \"v\" + i);
/* 发送消息*/
producer.send(record);

/*关闭生产者*/
producer.close();

这个样例中只配置了必须的这三个属性 , 其他都使用了默认的配置 。

发送消息Kafka

实例化生产者对象后 , 接下来就可以开始发送消息了 。 发送消息主要有三种方式: