Consumer之自动提交在上文中介绍了ProducerAPI的使用，现在我们已经知道如何将消息通过API发送到Kafka中了，那么现在的生产者/消费者模型就还差一位扮演消费者的角色了。因此，本文将介绍ConsumerAPI的使用，使用API从Kafka中消费消息，让应用成为一个消费者角色。还是老样子，首先我们得创建一个Consumer实例，并指定相关配置项，有了这个实例对象后我们才能进行其他的操
一、先写一个web框架，也就是后端服务器 1、服务端代码 import socket server = socket.socket(socket.AF_INET,socket.SOCK_STREAM) # 如果为空默认为TCP server.bind(("127.0.0.1",9000)) serv ...
分类：
其他好文 时间：
2020-05-23 09:26:02
阅读次数：
58
MySQL 数据操作 DML DML（Data Manipulation Language 数据操纵语言） DML是用来对数据库里的数据进行操作的语言。DML需要 commit。 当使用 mysql 客户端操作数据库时，这些语句都会自动提交，不用执行 commit。 插入数据（增加） 基础语法 /* ...
分类：
数据库 时间：
2020-05-18 14:37:32
阅读次数：
76
请求地址： https://abc.baidu.com/?track_number=1234567890 页面通过表单提交转发： <html> <head></head> <body onload="document.form1.submit()"> <form name="form1" metho ...
分类：
其他好文 时间：
2020-05-14 15:45:57
阅读次数：
63
消费者api，自动提交offset public class MyConsumer { public static void main(String[] args) { Properties props = new Properties(); //连接的集群 props.put(ConsumerCo ...
(1) 对事务的提交 MySQL默认是自动提交，而Oracle默认不自动提交，需要用户手动提交，需要在写commit;指令或者点击commit按钮(2) 分页查询 MySQL是直接在SQL语句中写"select... from ...where...limit x, y",有limit就可以实现分页 ...
分类：
数据库 时间：
2020-05-10 15:32:38
阅读次数：
124
站在巨人的肩膀上，我所写的东西，也会开源分享出来！已经能正常用了，但是还需优化一些小bug。 授人以鱼不如授人以渔，我把思路分享出来。 如果程序优化好了，我会将源码放在这里 "今日校园实现自动检测并提交最新表单" 也可以直接访问我 "博客" 一、抓包（重点） 1.1 如何抓包 Fiddler4电脑端 ...
分类：
编程语言 时间：
2020-05-08 13:30:20
阅读次数：
684
Spring-事务管理 事务的提交和回滚 交给spring 一.简述 JavaEE开发中，事务位于Service层， 由程序判断：出现异常事务回滚，未出异常事务提交。 Spring使用AOP技术进行事务控制，自行帮开发人员适时提交或者回滚事务 Spring：service层未出异常，事务自动提交 S ...
分类：
编程语言 时间：
2020-05-05 23:18:49
阅读次数：
70
JDBC实现事务（transaction) 1.事务的开启connection.setAutoCommit(false); 2.中间语句是事务的执行语句 3.事务的提交connection.commit(); ...
分类：
数据库 时间：
2020-05-01 18:53:17
阅读次数：
78
（1）Producer的API 1、发送流程：Kafka 的 Producer 发送消息采用的是异步发送的方式。在消息发送的过程中，涉及到了两个线程——main 线程和 Sender 线程，以及一个线程共享变量——RecordAccumulator。main 线程将消息发送给 RecordAccum ...
