高性能消息系统——Kafka


什么是Kafka?

 “ 官网:https://kafka.apache.org

它与传统的mq区别?



  • 模式
  • 模式

基本交互原理

默认路径/brokers/topics/<topic_id>/partitions/<partition_index>/state


基本CLI操作




Properties p = new Properties();
props.put("metadata.broker.list", "10.1.110.21:9092");
ProducerConfig config = new ProducerConfig(props);
Producer producer = new Producer<String, byte[]>(config);
producer.send(byte[] msg);

更具体的参见:https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example



相关内容

    暂无相关文章