前言 与生产者对应的是消费者，应用程序可以通过KafkaConsumer来订阅主题，并从订阅的主题中拉取消息。不过在使用KafkaConsumer消费消息之前需要先了解消费者和消费组的概念，否则无法理解如何使用KafkaConsumer。 <!--more--> Consumer 消费者（Consu ...
分类：
其他好文 时间：
2020-07-21 11:34:08
阅读次数：
71
Python访问MySQL的步骤 创建connection连接，连接数据库 获取cursor游标对象 执行SQL语句 关闭cursor游标对象 关闭connection连接 import pymysql user = input("username:") pwd = input("password: ...
分类：
数据库 时间：
2020-07-21 10:02:08
阅读次数：
87
gym调用gym的调用遵从以下的顺序env = gym.make('x')observation = env.reset()for i in range(time_steps):env.render()action = policy(observation)observation, reward, ... ...
分类：
其他好文 时间：
2020-07-21 09:54:32
阅读次数：
114
什么是Hive： 数据仓库软件，可以通过SQL读写和管理分布式存储的大型数据集，结构可以映射在已经存储的数据。用户可以通过命令行工具和JDBC连接到Hive。 Hive Commands： quit/exit：退出interactive shell reset：重置配置设定到默认值。 set =：设 ...
分类：
其他好文 时间：
2020-07-21 01:27:08
阅读次数：
119
抽象类 public abstract class JdbcTemplate { //template method public final Object execute(String sql) throws SQLException { Connection con = HsqldbUtil.g ...
分类：
数据库 时间：
2020-07-20 22:31:40
阅读次数：
92
用mina做了一个UDP接收的程序，绑定的时候没有指定IP，只是指定了端口。然后还是在本机连接127.0.0.1和UDP端口号，死活收不到数据。用TCP/UDP工具发送数据，提示如下： The virtual circuit was reset by the remote side executin ...
分类：
其他好文 时间：
2020-07-18 22:36:38
阅读次数：
154
BGP-community /peer-group/allowas-in ...
分类：
编程语言 时间：
2020-07-18 21:58:21
阅读次数：
58
1、安装wampserver 2、在wampserver3下快速配置多站点多目录 https://www.cnblogs.com/WalAmar/p/6136110.html 3、复制目录下的.env.example 重命名为.env 配置好数据库： DB_CONNECTION=mysql DB_H ...
分类：
其他好文 时间：
2020-07-17 19:35:52
阅读次数：
76
2020-07-17,9点43docker reset to default: 点开setting后点右上角的虫子.里面有reset. 2020-07-17,10点25 添加docker 磁盘空间的方法: 亲测完美.但是一定要要注意,#6里面的步奏,其实需要修改很多个 VhdSize需要都改成240 ...
在CentOS 7下，手工设置 /etc/resolv.conf 里的DNS，过了一会，发现被系统重新覆盖或者清除了。和CentOS 6下的设置DNS方法不同，有几种方式： 1、使用全新的命令行工具 nmcli 来设置 #显示当前网络连接 #nmcli connection show NAME UU ...
分类：
其他好文 时间：
2020-07-17 13:46:13
阅读次数：
100
