项目要结束了，最近在整理项目的相关文档，之前项目中在用hadoop jar **.jar提交作业时，设置了些公共依赖jar包到CLASSPATH中，这样算子在打包时就不需要把很多jar包再打进去离开 。在hadoop-env.sh中和mapreduce.application.classpath、yarn.application.classpath将jar都设置进去了，这样在本地执行hadoo

文章内容包含Kafka未进行序列化生产消费java示例，和使用Avro序列化数据进行生产和消费的示例，掌握这些之后就对Kafka的生产消费有基本开发基础。1.未序列化生产者示例：import java.util.Properties;import kafka.javaapi.producer.Producer;import kafka.producer.KeyedMessa