pip install setuptools pip install kafka-python执行以上两个命令就可以安装成功。说明：setuptools是kafka-python的依赖库 ...
分类：
编程语言 时间：
2021-03-17 14:49:03
阅读次数：
0
目录 一、Kafka的架构 二、Topics和Partition 三、Producer消息路由 四、Consumer Group 五、Push vs. Pull 六、Kafka delivery guarantee 正文 回到顶部 一、Kafka的架构 如上图所示，一个典型的Kafka集群中包含若干 ...
分类：
其他好文 时间：
2021-03-17 14:25:54
阅读次数：
0
大数据技术板块划分 数据采集 flume kafka logstash filebeat ... 数据存储 mysql redis hbase hdfs ... 虽然mysql不属于大数据范畴 但是我在这也列出来了，因为你在工作中离不开它 数据查询 hive impala elasticsearch ...
分类：
其他好文 时间：
2021-03-17 14:04:41
阅读次数：
0
问题：springboot集成kafka，并由KafkaStreams处理，启动报错 org.apache.kafka.streams.errors.StreamsException: Input record ConsumerRecord(topic = crawler_events, parti ...
分类：
编程语言 时间：
2021-03-16 14:11:28
阅读次数：
0
Java入门及环境搭建 一、Java基本概念 Java开发环境 JVM：Java Virtual Machine（Java虚拟机） ? 源文件（myProgram.java)→编译器（Compiler) →字节码文件（myProgram.class)→解释器（Interpreter）→程序 JRE： ...
分类：
编程语言 时间：
2021-03-16 13:46:49
阅读次数：
0
目录 引言 1 背景 2 什么是最优运输？ 3 基本概念 3.1离散测度 (Discrete measures) 3.2蒙日(Monge)问题 3.3 Kantorovich Relaxation (松弛的蒙日问题) 3.4 Wasserstein距离 3.5最优运输问题初解 3.6 熵(Entro ...
分类：
其他好文 时间：
2021-03-15 10:35:23
阅读次数：
0
TopN的常见应用场景，最热商品购买量，最高人气作者的阅读量等等。 1. 用到的知识点 Flink创建kafka数据源； 基于 EventTime 处理，如何指定 Watermark； Flink中的Window，滚动（tumbling）窗口与滑动（sliding）窗口； State状态的使用； P ...
分类：
其他好文 时间：
2021-03-12 13:00:59
阅读次数：
0
Springboot的基本概念、演变的历史 基本概念 Spring是一个开源框架，2003年兴起的一个轻量Java开发框架。Spring是为了解决企业级应用开发的复杂性而创建的，简化开发。 Spring Boot 以约定大于配置的核心思想，默认帮我们进行了很多设置，多数 Spring Boot 应用 ...
分类：
编程语言 时间：
2021-03-10 13:19:06
阅读次数：
0
函数 函数的基本概念 package main import ( "fmt" ) // 函数 // 函数存在的意义:函数能够让代码结构更加清晰，更简洁，能够让代码复用 // 函数是一段代码的封装 // 把一段逻辑抽象出来封装到一个函数中，给他起个名字，每次用它的时候直接用函数名调用即可 // 函数的 ...
分类：
编程语言 时间：
2021-03-09 13:18:49
阅读次数：
0
文件名 —————————————————————————————— 文件名全部小写，可以含下划线或连字符，按项目约定命名,且尽量保证文件名明确。比如： cmd_save_player_info_class.cc my_use_full_class.cc 定义类的文件名一般是成对出现，如：foo_b ...
分类：
编程语言 时间：
2021-03-08 13:07:04
阅读次数：
0
