AdminClient 类提供了创建 topic，删除 topic 的 api。 在项目中创建了一个 AdminClient 对象，每次创建 topic 时，调用 如果长时间不使用这个对象，客户端与 broker 之间的连接会被关掉，相关的参数： 这个最大空闲参数在 broker 和 客户端都可以配 ...
分类：
其他好文 时间：
2019-01-18 19:56:22
阅读次数：
514
kafka集群扩容后的topic分区迁移 ./bin/kafka-topics.sh --zookeeper node3:2181,node4:2181,node5:2181 --alter --topic dftt --partitions 4 kafka集群扩容后，新的broker上面不会数据进 ...
分类：
其他好文 时间：
2019-01-17 16:52:00
阅读次数：
253
kafka 的心跳是 kafka consumer 和 broker 之间的健康检查，只有当 broker coordinator 正常时，consumer 才会发送心跳。 consumer 和 reblance 相关的 2 个配置参数： broker 端，sessionTimeoutMs 参数 b ...
分类：
其他好文 时间：
2019-01-17 15:17:01
阅读次数：
1337
介绍 RabbitMQ 是一个消息中间人（broker）: 它接收并且发送消息. 你可以把它想象成一个邮局: 当你把想要寄出的信放到邮筒里时, 你可以确定邮递员会把信件送到收信人那里. 在这个比喻中, RabbitMQ 就是一个邮筒, 同时也是邮局和邮递员 . 和邮局的主要不同点在于RabbitMQ ...
分类：
编程语言 时间：
2019-01-17 12:54:36
阅读次数：
244
RabbitMQ是一个开源的消息代理和队列服务器，用来通过普通协议在完全不同的应用之间传递数据，RabbitMQ是使用Erlang语言来编写的，并且RabbitMQ是基于AMQP协议的。 特点： AMQP核心概念 Server：又称Broker，接收客户端的连接，实现AMQP实体服务 Connect ...
分类：
其他好文 时间：
2019-01-15 16:59:41
阅读次数：
168
今天遇到一个情况使用了 Kafka-python 1.3.3 来操作读取 broker 1.0.1 版本的 kafka。出现了 rebalance 之后分配到了客户端，但是 cpu 利用率很高且无法消费的情况。 先是排查了连接方面和代码方面的问题，后来发现都没有问题就把注意力转移到了 kafka-c ...
分类：
编程语言 时间：
2019-01-14 14:39:15
阅读次数：
755
概述 Oracle Data Guard 是针对企业数据库的最有效和最全面的数据可用性、数据保护和灾难恢复解决方案。它提供管理、监视和自动化软件基础架构来创建和维护一个或多个同步备用数据库，从而保护数据不受故障、灾难、错误和损坏的影响。一台主数据库最多可以配备9个备数据库。 原理 一、创建DG的大致 ...
分类：
系统相关 时间：
2019-01-09 18:39:36
阅读次数：
169
基本配置如下：-broker.id-log.dirs-zookeeper.connectTopic-level配置以及其默认值将在下面讨论。 Property Default Description broker.id 每个broker都可以用一个唯一的非负整数id进行标识；这个id可以作为brok ...
分类：
其他好文 时间：
2019-01-07 21:19:08
阅读次数：
342
AMQP 协议模型 server: 又称broker，作用是接受客户端连接。 channel :网络信道 ：几乎所有的操作都在channel上进行。客户端可以建立多个channel，每个channel代表一个会话任务，类似于数据库的session。 message：传递的实体数据，其结构由两部分组成 ...
分类：
其他好文 时间：
2019-01-07 01:35:20
阅读次数：
269
如果RabbitMQ集群只有一个broker节点，那么该节点的失效将导致整个服务临时性的不可用，并且可能会导致message的丢失（尤其是在非持久化message存储于非持久化queue中的时候）。可以将所有message都设置为持久化，并且使用持久化的queue，但是这样仍然无法避免由于缓存导致的 ...
分类：
其他好文 时间：
2019-01-06 20:04:23
阅读次数：
234
