启动kafka自带的zookeeper 启动kafka 创建一个叫做“test”的topic,它只有一个分区,一个副本。 查看创建的topic 发送消息 接受消息 {"id":"b18a865a-fe8d-465d-bc67-865e51e348cd","msg":"zhangxianlong,ma ...
分类:
其他好文 时间:
2018-11-04 14:16:42
阅读次数:
149
原文地址:https://medium.com/open-machine-learning-course/open-machine-learning-course-topic-9-time-series-analysis-in-python-a270cb05e0b3 Open Machine Lea ...
分类:
其他好文 时间:
2018-11-04 00:32:34
阅读次数:
986
【转自】jQuery 用each后添加click mydd = $('.plist'); mydd.each(function(i){ $(this).click(function(){ mydl.eq(i).hide("slow"); }) }); 注意:此处 this 指代的是 DOM 对象而非 ...
分类:
Web程序 时间:
2018-11-01 00:50:07
阅读次数:
257
1.kafka日志结构 直接举例子: 例如kafka有个名字叫 haha 的topic,那么kafka日志下面有kafka-0,kafka-1,kafka-2...,kafka-n,具体多少个,创建分区的时候有几个分区,n就是几。 每个目录下面有三个日志文件,xxx.log是消息集文件, xxx.i ...
分类:
其他好文 时间:
2018-10-31 21:42:05
阅读次数:
149
RabbitMQ 原文地址: https://baijiahao.baidu.com/s?id=1577456875919174629&wfr=spider&for=pc 最新版本的RabbitMQ有四种交换机类型,分别是Direct exchange、Fanout exchange、Topic e ...
分类:
其他好文 时间:
2018-10-31 20:08:36
阅读次数:
174
Flume和Kafka完成实时数据的采集 写在前面 Flume和Kafka在生产环境中,一般都是结合起来使用的。可以使用它们两者结合起来收集实时产生日志信息,这一点是很重要的。如果,你不了解flume和kafka,你可以先查看我写的关于那两部分的知识。再来学习,这部分的操作,也是可以的。 实时数据的 ...
分类:
Web程序 时间:
2018-10-31 15:49:53
阅读次数:
526
Kafka部署与使用 写在前面 从上一篇Kafka的架构介绍和安装中,可能,你还一直很蒙,kafka到底该怎么使用呢?接下来,我们就来介绍Kafka的部署与使用。上篇文章中我们说到,Kafka的几个重要组成是:1.producer 2.consumer 3.broker 4.topic .因此我们就 ...
分类:
其他好文 时间:
2018-10-31 15:39:08
阅读次数:
106
Be on-topic Our community is defined by a specific set of topics in the help center; please stick to those topics and avoid asking for opinions or ope ...
分类:
其他好文 时间:
2018-10-31 13:59:03
阅读次数:
181
前言 我们在浏览器访问一个网页是通过url地址去访问的,django管理url配置是在urls.py文件。当一个页面数据很多时候,通过会有翻页的情况,那么页数是不固定的,如:page=1. 也就是url路径里面带参数时候如何去处理呢? urls.py配置规则 由于django版本比较多,在查资料时候 ...
分类:
编程语言 时间:
2018-10-30 23:52:08
阅读次数:
256
kafka消息存储机制 (一)关键术语 复习一下几个基本概念,详见上面的基础知识文章。 Broker:消息中间件处理结点,一个Kafka节点就是一个broker,多个broker能够组成一个Kafka集群。 Topic:一类消息,比如page view日志、click日志等都能够以topic的形式存 ...
分类:
其他好文 时间:
2018-10-30 21:56:50
阅读次数:
253