Kafka入门(一)
一,消息队列的分类
1,点对点
消息生产者生产消息发送到queue中,然后消息消费者从queue中取出并且消费消息。
注意:1,消息被消费以后,queue中不再有存储,所以消息消费者不可能消费到已经被消费的消息。
kubernetes之Namespace详解
Namespace
Namespace是对一组资源和对象的抽象集合,比如可以用来将系统内部的对象划分为不同的项目组或用户组。常见的pods, services, replication controllers和deployments等都是属于某一个namespace的(默认是default),而node, persistentVolumes等则不属于任何namespace。
Flink在美团的实践与应用
Kafka作为最大的数据中转层,支撑了美团线上的大量业务,包括离线拉取,以及部分实时处理业务等。在数据缓存层之上,是一个引擎层,这一层的左侧是我们目前提供的实时计算引擎,包括Storm和Flink。
Kafka消息序列化和反序列化(下)
接上一篇:Kafka消息序列化和反序列化(上)。
有序列化就会有反序列化,反序列化的操作是在Kafka Consumer中完成的,使用起来只需要配置一下key.deserializer和value.deseriaizer。
openstack rpc机制
一、概述:
在openstack项目中,api的调用规则:
跨项目:如nova调用keystone, glance,cinder等,使用rest api(通过相应的python-XXXclient 库)
项目内跨服务调用,使用RPC调用,通过服务提供的rpcapi.