BigData16:Kafka

启动Kafka

1. 终端1启动Zookeeper服务

2. 终端2启动Kafka

3. 终端3测试Kafka

4. 终端四启动一个消费者

• Spark版本与Kafka版本对应

SparkStreaming程序使用Kafka数据源

1. 编写生产者（producer）程序

2. 编写消费者（consumer）程序

3. 编写日志格式设置程序

4. 编译打包程序

5. 运行程序