Kafka源碼分析--生產者

ps.本文所有源碼都基於kafka-0.10.0.1 Kafka提供了Java版本的生產者實現--KafkaProducer，使用KafkaProducer的API可以輕鬆實現同步／異步發送消息、批量發送、超時重發等複雜的功能，KafkaProducer是線程安全的，多個線程之間可以共享實用同一個KafkaProducer對象。 下面先看一個使用上的小例子： public static void

>>阅读原文<<