, 可以发送键值对的, 此处是用来定义k v的序列化的类型 props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer..."); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");..., 可以发送键值对的, 此处是用来定义k v的序列化的类型 props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer...释放资源 producer.close(); }}生产者代码3: 异步发生数据, 带有回调函数操作package com.it.producer;import org.apache.kafka.clients.producer..., 可以发送键值对的, 此处是用来定义k v的序列化的类型 props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer