1.启动zookeeperbin/zookeeper-server-start.sh &2.启动kafka nohup bin/kafka-server-start.sh config/server.properties & 3.创建topicbin/kafka-topics.sh --create ...
分类：
其他好文 时间：
2017-08-16 17:30:40
阅读次数：
141
阿里云防火墙关闭，并且配置规则。不然会导致访问不到服务。 问题一： Caused by: java.net.UnknownHostException: iZuf68tztea6l5ccdz7wemZ: iZuf68tztea6l5ccdz7wemZ: Name or service not know ...
分类：
其他好文 时间：
2017-08-16 15:27:21
阅读次数：
1096
前面说过Kafka集群环境的部署，现在主要说一下在本地测试中Kafka单机环境的部署，和前面一样首先保证zookeeper服务的正常运行，然后解压并释放kafka安装包，并放到指定位置： 现在开始编辑配置文件server.properties，执行命令： vim config/server.prop ...
分类：
其他好文 时间：
2017-08-11 13:31:20
阅读次数：
138
############################# System ############################# #唯一标识在集群中的ID，要求是正数。 broker.id=0 #服务端口，默认9092 port=9092 #监听地址，不设为所有地址 host.name=debu ...
分类：
其他好文 时间：
2017-08-10 19:51:36
阅读次数：
173
1，简介 RabbitMQ（Rabbit Message Queue）是流行的开源消息队列系统，用erlang语言开发。 1.1关键词说明： Broker：消息队列服务器实体。Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。Queue：消息队列载体，每个消息都会被投入到一个或多个 ...
分类：
编程语言 时间：
2017-08-09 13:00:59
阅读次数：
832
1. SAL架构 系统的体系结构如下图所示： 上图中的子系统如下： 生产者(Provider)--通过其北向API向应用程序和其他提供程序（插件）提供公开功能的组件。生产者可以是其他生产者的消费者。生产者有两种类型： 绑定无关生产者：它们的功能以绑定无关的数据DOM格式公开; 绑定感知生产者：它们的 ...
分类：
其他好文 时间：
2017-08-05 10:56:15
阅读次数：
190
1. kafka整体结构图 Kafka名词解释和工作方式 Producer ：消息生产者，就是向kafka broker发消息的客户端。 Consumer ：消息消费者，向kafka broker取消息的客户端 Topic ：咋们可以理解为一个队列。 Consumer Group （CG）：这是ka ...
分类：
其他好文 时间：
2017-08-01 20:37:35
阅读次数：
166
1、kafka生产者是线程安全的，她允许多个线程共享一个kafka实例 2、kafka管理一个简单的后台线程，所有的IO操作以及与每个broker的tcp连接通信，如果没有正确的关闭生产者可能会造成资源泄露。 kafka总共有以下的这些生产者实例 以及相应的方法 主要介绍send方法 ...
分类：
其他好文 时间：
2017-07-30 11:30:28
阅读次数：
170
Kafka使用ZooKeeper 首先进入ZooKeeper客户端： ls / 可以看到有以下节点： 查看Topic 配置信息：体现了ZooKeeper的配置管理 查看broker leader: (体现leader election功能) 查看broker id 信息：（体现ZooKeeper服务 ...
分类：
其他好文 时间：
2017-07-29 16:34:49
阅读次数：
120
目前业界有很多MQ产品，我们作如下对比： RabbitMQ 是使用Erlang编写的一个开源的消息队列，本身支持很多的协议：AMQP，XMPP, SMTP, STOMP，也正是如此，使的它变的非常重量级，更适合于企业级的开发。同时实现了一个经纪人(Broker)构架，这意味着消息在发送给客户端时先在 ...
分类：
其他好文 时间：
2017-07-28 22:34:26
阅读次数：
143
