很喜欢玩docker，但最新遇到一个问题，公司给的新机器的dns有问题，导致pull不下来镜像。" style="border:0px; vertical-align:middle; outline:none; max-width:100%; color:rgb(69,69,69); font-family:"PingFang SC","Microsof

可以使用命令:docker tag [image id] [name]:[版本]例如:docker tag b03b74b01d97 docker-redis:0.0.1

object DirectStream {def main(args: Array[String]): Unit = {//创建SparkConf，如果将任务提交到集群中，那么要去掉.setMaster("local[2]")val conf = new SparkConf().setAppName("DirectStream").setMaster(&qu

Kafka支持的基本命令位于${KAFKA_HOME}/bin文件夹中，主要是kafka-topics.sh命令；Kafka命令参考页面:kafka-0.8.x-帮助文档  -1. 查看帮助信息bin/kafka-topics.sh --help -2. 创建Topicbin/kafka-topics.sh --create --topic test0 --z

在前面简单搭建了Windows上的kafka环境，并使用命令行测试可以运行之后（环境请参考：http://blog.csdn.net/u014104286/article/details/75040932）我们会考虑怎么使用kafka；先试着发送一个简单的消息，发送成功之后是否需要发送自定义的消息类尼？怎么发送自定义的消息类，如果我要发送一个集合呢？下面我们来一一解决我们的问题。准备工作：1.需要