主题+客户端发布订阅的对象是主题（Topic）向主题发布消息的客户端应用程序称为生产者（Producer），生产者可以持续不断地向多个主题发送消息订阅这些主题消息的客户端应用程序称为消费者（Consumer），消费者能够同时订阅多个主题的消息生产者和消费者统称为客户端服务端Kafka的服务端由被称为Broker的服务进程构成，一个Kafka集群由多个Broker组成Broker负责接收和处理客户端
分类：
编程语言 时间：
2019-07-01 21:41:06
阅读次数：
169
1.生产者命令： ./kafka-console-producer.sh --topic mytopic --broker-list node06:9092,node07:9092,node08:9092 2.消费者命令： ./kafka-console-consumer.sh --bootstra ...
分类：
其他好文 时间：
2019-06-29 00:26:50
阅读次数：
79
1. Kafka 总体架构 基于 Kafka-ZooKeeper 的分布式消息队列系统总体架构如下： 如上图所示，一个典型的 Kafka 体系架构包括若干 Producer（消息生产者），若干 broker（作为 Kafka 节点的服务器），若干 Consumer（Group），以及一个 ZooKe ...
分类：
其他好文 时间：
2019-06-28 14:49:18
阅读次数：
106
本地开发spark streaming无法消费云主机kafka消息
分类：
其他好文 时间：
2019-06-22 23:50:02
阅读次数：
234
信号量（semaphore），也和互斥锁一样提供了线程间或者进程间的同步功能。 信号量有三种： "Posix有名字的信号量" Posix基于内存的信号量 System V信号量 信号量比互斥锁高级，互斥锁只允许一个线程访问临界区，信号量可以多个，可以把信号量看作成互斥锁的升级版，但是如果能用互斥锁解 ...
分类：
系统相关 时间：
2019-06-22 19:53:26
阅读次数：
156
这里实现一个用神经网络(卷积神经网络也可以)实现验证码识别的小案例，主要记录本人做这个案例的流程，不会像之前那么详细，主要用作个人记录用。。。 这里是验证码的四个字母，被one-hot编码后形成的四个一维数组，[1, 26] * 4 > 可以转变成[4, 26] > [1, 104] 第一个位置：[ ...
分类：
其他好文 时间：
2019-06-22 10:40:18
阅读次数：
100
增加PUT/ecommerce/product/1{"name":"gaolujieyagao","desc":"gaoxiaomeibai","price":30,"producer":"gaolujieproducer","tags":["meibai","fangzhu"]}PUT/ecommerce/product/2{"name":"jiajieshiyagao","desc":"gao
分类：
其他好文 时间：
2019-06-21 23:54:01
阅读次数：
442
一个典型的Kafka体系结构包括若干Producer、若干Broker、若干Consumer，以及一个ZooKeeper集群，如下图所示。其中ZooKeeper是Kafka用来负责集群元数据的管理、控制器的选举等操作的。Producer将消息发送到Broker，Broker负责将收到的消息存储到磁盘 ...
分类：
其他好文 时间：
2019-06-21 12:32:09
阅读次数：
86
从 AMQP 协议可以看出，Queue、Exchange 和 Binding 构成了 AMQP 协议的核心 Producer：消息生产者，即投递消息的程序。 Broker：消息队列服务器实体。 Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。 Binding：绑定，它的作用就是把 ...
分类：
其他好文 时间：
2019-06-16 00:23:36
阅读次数：
98
