Kafka的體系結構

  /** * 生產者 */ public class TestProducer { public static void main(String[] args) throws Exception { Properties props = new Properties(); props.put("bootstrap.servers", "node4:9092,node2:9092,node3:90

>>阅读原文<<