Kafka的單線程生產消費測試

代碼: package com.weichai.kafka; import java.util.Properties; import kafka.javaapi.producer.Producer; import kafka.producer.KeyedMessage; import kafka.producer.ProducerConfig; /** * Kafka生產者的簡單示例 *
相關文章
相關標籤/搜索