前言 要了解生产者ISR,需要提前了解下生产者重试机制和应答机制 生产者重试机制 创建生产者时,可以指定retries参数,如果向broker发送消息时抛出异常,并且异常是可重试异常RetriableException,那么此时就会按照指定的次数进行重试 1、哪些情况下可以重试 (1)没有到deli ...
                            
                            
                                分类:
其他好文   时间:
2020-05-31 18:19:32   
                                阅读次数:
105
                             
                    
                        
                            
                            
                                    1.Confirm消息确认机制 消息的确认:是指生产者投递消息后,如果Broker收到消息,则会给生产者一个应答。 生产者进行接收应答,用来确定这条消息是否正常的发送到Broker,这种方式也是消息的可靠性投递的核心保障。 生产端 public static void main(String[] a ...
                            
                            
                                分类:
其他好文   时间:
2020-05-29 13:36:50   
                                阅读次数:
47
                             
                    
                        
                            
                            
                                由于主库和备库的db_name相同的,只是db_unique_name不同,可以使用备库进行数据库的备份,从而减轻主库备份的负担。本篇演示DataGuard环境下RMAN工具的使用。 1 查看主库RMAN配置 [oracle@sz ~]$ rman target / catalog rman/rma ...
                            
                            
                                分类:
其他好文   时间:
2020-05-27 20:52:13   
                                阅读次数:
74
                             
                    
                        
                            
                            
                                前面介绍了如何通过RMAN Duplicate方式构建物理备用数据库,本篇将演示如何利用Cloud Control构建物理备用数据库。 1 软件环境 Oracle Linux 6.9 Oracle 12.1.0.2 Oracle Enterprise Management Cloud Control ...
                            
                            
                                分类:
数据库   时间:
2020-05-27 20:17:32   
                                阅读次数:
80
                             
                    
                        
                            
                            
                                1 软件环境 Oracle Linux 6.9 Oracle 12.1.0.2 主库:sz.oracle.com,IP:192.168.1.102 备库:sh.oracle.com,IP:192.168.1.103 2 主数据库配置 2.1 检查并设置数据库 1)首先,主数据库必须处于强制日志(Fo ...
                            
                            
                                分类:
数据库   时间:
2020-05-27 20:17:03   
                                阅读次数:
65
                             
                    
                        
                            
                            
                                Data Guard环境中数据库的角色转换有两种,分别为Switchover和Failover,通过名称可知,前者是正常的主备库之间的角色切换,该切换方式不会丢失数据;后者是故障切换,即主库不能继续提供服务的切换,可能发生数据丢失。从12.1版本开始,切换到物理备库的操作得以简化,本篇分别对这两种切 ...
                            
                            
                                分类:
其他好文   时间:
2020-05-27 20:14:11   
                                阅读次数:
57
                             
                    
                        
                            
                            
                                    Kafka最初考虑的问题是,customer应该从brokes拉取消息还是brokers将消息推送到consumer,也就是pull还push。在这方面,Kafka遵循了一种大部分消息系统共同的传统的设计:producer将消息推送到broker,consumer从broker拉取消息。 一些消息系 ...
                            
                            
                                分类:
其他好文   时间:
2020-05-27 09:22:10   
                                阅读次数:
405
                             
                    
                        
                            
                            
                                    Kafa consumer消费消息时,向broker发出fetch请求去消费特定分区的消息,consumer指定消息在日志中的偏移量(offset),就可以消费从这个位置开始的消息,customer拥有了offset的控制权,可以向后回滚去重新消费之前的消息,这是很有意义的 ...
                            
                            
                                分类:
其他好文   时间:
2020-05-26 21:58:05   
                                阅读次数:
373
                             
                    
                        
                            
                            
                                Kafka快速入门(七)——Kafka监控一、Kafka监控指标1、Kafka主机监控指标主机监控是监控Kafka集群Broker所在的节点机器的性能。常见的主机监控指标包括:(1)机器负载(Load)(2)CPU使用率(3)内存使用率,包括空闲内存(FreeMemory)和已使用内存(UsedMemory)(4)磁盘I/O使用率,包括读使用率和写使用率网络(5)I/O使用率(6)TCP连接数(7
                            
                            
                                分类:
其他好文   时间:
2020-05-26 10:38:25   
                                阅读次数:
75
                             
                    
                        
                            
                            
                                应用场景由于朋友所在公司对安全性要求较高,zabbix所在的网络环境不能上外网,因此不能通过zabbix将告警直接发送至一些即时通讯工具,这就需要将报警消息发送至一些中间件,并通过中间件转发出去,这里选择使用了kafka,当然kafka中不只有报警信息,也有其他需要发送的数据,这里就不过多透漏基础环境配置kafka集群已部署好,这里不介绍安装细节vim/etc/hosts192.168.179.1
                            
                            
                                分类:
其他好文   时间:
2020-05-26 10:32:24   
                                阅读次数:
118