如果您使用的是0.9或更高版本,则可以使用最新的客户机消费者.seekToEnd() / 消费者地位()可用于获取最新偏移量:${日志.dirs}/复制偏移量检查点
我来这里玩的时候,我什么都没做。我开始在各种网络上寻找技术信息,然后我把重点放在标题上。从寻找信息到交朋友。因为我觉得事情落后于时代,有人认为,是因为自己水平不高。只是在心里想,无法实现现实
请参阅文档https://pykafka.readthedocs.io/en/latest/index.html
有两种选择。
Scheme 1 Local message transaction table
生产者需要添加一个事务消息表。具体步骤如下:[1。生产者执行业务逻辑并将事务记录插入到消息表中。这两个操作在一个本地事务中
2。启动后台线程定期轮询消息表并将消息发送到消息队列
3。删除消息表中的消息,直到发送成功。
方案2需要消息队列支持,业务端提供回溯接口
1。生产端将准备好的消息发送到消息队列
2。在本地事务中,业务逻辑
3。根据执行结果确认或取消准备好的消息
4。消息队列将确保准备好的消息被确认或取消,并且消息队列将不断地向生产端请求执行结果,这要求生产端提供类似的回调函数。
在方案2中,消息队列取代了方案1中的消息表和后台线程轮询功能,但并非所有消息队列都支持此功能。支持Rocketmq。
方案1的开发工作量大,外部依赖性小
方案2的开发工作量小,但依赖于特定的消息队列。
JAVA导入txt、CSV的例子?如果导入文件是二进制格式的CSV或XLS文件,则需要使用jxl.jar文件要分析的包。如果文件是文本格式的逗号分隔CSV文件,则需要使用opencsv.jar文件包裹。下面是导入两种格式文件的代码示例:1。
数据字典怎么写?数据字典应包括以下六个部分:1。写入数据项:数据项描述={数据项名称、数据项含义描述、别名、数据类型、长度、值范围、值含义、与其他数据项的逻辑关系}。其中,“值范围”和“与其他数据项的逻辑关系”定义了数据完整性约束,是设计数
oracle如何把数据库查询结果导出?如果是oracle命令行的话,可以用spool,这个有点复杂,需要研究一下。 如果是oraclesqldeveloper,这个也是可以导出成excel、文本文件等文件的,总之就是在重新结果那儿右键导出
有没有免费设计房屋的网站推荐一下?我们需要明白,我们有理由支付我们的货物。返回问题。其实也有免费的设计网站,比如库嘉乐,可以自己设计,但细节还不够。学习一个软件需要花费一定的时间和精力。
如何制作网站?首先,个人电脑网站现在正处于衰退期,移动是目前比较好的方式。在我不知道你的个人网站的目的,我可以简单地回到如何建立自己的网站:1。首先,你需要注册自己的域名。你可以去www.net.cn万网急于注册自己想要的域名。2. 做好万
nao机器人值得买吗?完全可以编程。智能机器人多少钱一个?芒果智能语音机器人,很负责的说,小编这个问题,很幼稚!就像在问:现在一辆车多少钱?这是事实。智能机器人的用途、品牌、系统特点、生产厂家等,多种因素决定其价格。
DW手表怎么看型号?1、模型视图1。从保修卡上识别型号,相应手表的完整型号将显示在手表的保修卡上。2从手表封底识别手表型号最简单、最直接的方法是在手表封底上显示手表型号,但只显示部分型号。完整的数字,您需要检查相应的保修卡。2、 手表型号的
什么是企业邮箱?企业邮箱有什么作用?企业电子邮件是以自己的域名作为后缀的收费电子邮件。例如,企业的域名是abc网站则企业邮箱的电子邮件地址为abc@abc.com. 企业邮箱对企业形象意义重大,其功能往往比普通免费邮箱或收费邮箱更丰富。企业
网络营销主管主要负责什么工作?��络营销主管在实际中也可以理解为运营总监、运营经理、网络营销项目经理等,主要负责公司网络营销项目整体的规划、运营、执行,对效果负责~一般来讲要有丰富的项目经验,具备一定的营销、策划能力,项目规划控制能力,统筹
对于大文本文件的读写有哪些高效的方法?使用RandomAccessFile的class方法读取文件的速度要比一般方法快得多,然后使用缓冲区编写器将结果写入TXT。