Kafka 是一个分布式流媒体平台 kafka官网： （1）流媒体平台有三个关键功能： 发布和订阅记录流，类似于消息队列或企业消息传递系统。 以 容错的持方式存储记录流 。 记录发生时处理流。 （2）Kafka如财期势灯象什列波提通常用于两大类应用： 构建可在发件知露势田系统或应用程序之间来自可靠获取数据的实时流数据管道 构建转换或响应数实时流应用程序 topic：Kafka将消息分别类，每一类的消息称之为一个主题（Topic） producer：发布无追搜索消息的对象称之为主题生产者（Kafka to producer） consumer：订阅消并处理发布的消息的对象称之为主题消费者（consumers） broker：已发布的消息保存在一组服务器中，称之为Kafka集群。集群中的个服务器都是一个代理（Broker）。消费者可以订阅一个或多个主题（topic），并从Broker拉数据，从而消费这些已发布的消息。 import org.apache.kafka.cli京示洲仍员每ents.producer.KafkaProducer; mport org.apache.kafka.ents.producer.Produce道讲新民官真陆宗环rConfig; impor还交家t org.apache.ka.clients.pr且独简氧oducer.ProducrRecord; import java.util.Prope客东怎行市效满总该季本rties; /** * 息生产者 * kafka的一条消息由key-vaue组成 * key：消息标记用于指定不同的分区内容 * value：消息主主体内容 * （默认走序列化，也可以选择字符串） */ pulic class ProducerQuickStart { public static void ma脸天此够饭制in(String[] args) { //1.配置参数 Propertie roperties = new Properties(); //启动服务器 properties.put(Produc试吗师每便胡甲erConfig.BOOTSTRAP_SERVERS_CONFIG,127.0.0.1:9092); //key序列化施记引器 properties.p社块ut(Produc表使往类协货胞面倒erConfig.KEY_SERIALIZER_CLASS_COFIG,org.apache.kafka.c犯候角新虽商零曲这定电ommon.serialization.Strin谈煤那地门号gSerializer); //修改序列化机制为字 /value序列化器 propertie陈责既非爱肉s.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,org.apache.kafka.common.serialization.St老伤高ringSeriaizer); //2.创建生产者对象 Kafkoducer kafkaProducer 审蛋布侵观右领生换肉= new KafkaProducer(prorties); //3.创建消息 //参