最近搞了一下rocketmq消息中间件，使用了Apache提供的与springboot封装的rocketmq-spring-boot-starter，版本是2.1.0的，生产者使用方式和其他的消息中间件一样如下：@Resourceprivate RocketMQTemplate rocketMQTemplate;@GetMapping(value = "/mq/{name}")public Str

            在kafka集群的单服务器情况下，如何通过consumer消费者确定kafka服务器或者zookeeper服务器是否启动(因为消费者目前是无法判断服务器是否启动的，它只是去轮询获取服务器数据而不报错)，如果没有启动，消费者端做出相应的操作来提醒消费者端使用人员进行维护，在这里我提供一个简单的解决方案，可能并不是非常通用，提供一个简单的思路而已。         如果...

前面我们了解完broker的配置，现在我们来看下topic的配置：1.cleanup.policy字符串要么是“delete”，要么是“compact”，或者两者都是。此配置指定在旧日志段上使用的保留策略。默认策略(“delete”)将在达到保留时间或大小限制时丢弃旧段。“compact”设置将启用topic上的日志压缩。服务器提供的默认配置是log.cleanup.policy。2.compre

kafka connect是用于与其他数据系统进行数据交换的工具，它具有可扩展性和可靠性，它可以将其他数据系统的数据通过topic的方式导入到kafka，而kafka的导出功能能将topic导出到其他数据系统使用。kafka connect提供了以下功能：1.kafka connect通用框架：它包含了一些主流的数据系统框架集成，可以做到简化连接器的开发、部署和管理。2.有分布式和单机部署模式：可

下面我们来看下连接到第三方数据仓库的connect config配置：1.config.storage.topic存储连接器配置的Kafka topic的名称。2.group.id标识此工作者所属的连接集群组的唯一字符串。3.key.converter用于配置key转换器类，用于在Kafka连接格式和写入Kafka的序列化格式之间进行转换。它控制写入或从Kafka读取的消息中的键的格式，并且由于它

在上面一篇文章中简单介绍了Redis的主从复制，因为有了主从复制的机制Redis就可以保证高可用，不用担心因为单机故障的原因导致整个环境的性能压力，但是如果master主节点挂掉了怎么办呢？白天还好，如果是半夜两三点我们还必须从暖和的被窝赶到公司重启服务，特别是冬天的时候别提有多酸爽了，当然你可以说我们可以让master节点自动重启啊，当然也可以，但是这里有另外一个问题啊，maste...

转载自：http://blog.csdn.net/forezp/article/details/74820899 本文出自方志朋的博客 什么是RibbonRibbon是Netflix公司开源的一个负载均衡的项目，它属于上述的第二种，是一个客户端负载均衡器，运行在客户端上。它是一个经过了云端测试的IPC库，可以很好地控制HTTP和TCP客户端的一些行为。 Feign已经默认使用了R...

在nginx中为了避免因为后端服务器异常带来的接口不可用，nginx提供了主动健康检测模块nginx_upstream_check_module(淘宝开源提供)和被动检测ngx_http_upstream_module，我们先说下被动检测ngx_http_upstream_module，可以在upstream指令块中的server子指令参数max_fails、fail_timeout来进行被动检测

kafka的核心配置是：broker.id--节点idlog.dirs--日志路径zookeeper.connect--zookeeper的连接地址节点重新配置后有3种启动方式：read-only:需要重新启动broker进行更新。per-broker:可以为每个broker动态更新。cluster-wide:可以作为集群范围的默认值动态更新，也可以为测试更新为每个broker的值。下面分别看下服

接下来在看下producer生产者的配置：1.key.serializer实现org.apache.kafka.common.serialization.Serializer接口的键的序列化器类。2.value.serializer用于实现org.apache.kafka.common.serialization.Serializer接口的值的序列化器类。3.acks生产者要求leader在考虑完