云消息队列 Kafka 版

首页 标签 云消息队列 Kafka 版
分布式消息通信及流行MQ框架
分布式系统消息通信技术简介 分布式系统消息通信技术主要包括:RPC(Remote Procedure Call Protocol) 一般是C/S方式,同步的,跨语言跨平台,面向过程CORBA(Common Object Request Broker Architecture) 从概念上扩展了RPC,面向对象的,企业级的 面向对象中间件还有分布式组件对象模型DCOMRMI(Remote Method Invocation) 面向对象方式的 Java RPCWebService 基于Web,C/S或B/S,跨系统跨平台跨网络。
趣头条基于 Flink 的实时平台建设实践
本文由趣头条实时平台负责人席建刚分享趣头条实时平台的建设,整理者叶里君。文章将从平台的架构、Flink 现状,Flink 应用以及未来计划四部分分享。
史上最全Java面试266题:算法+缓存+TCP+JVM+搜索+分布式+数据库
JAVA基础 JAVA中的几种基本数据类型是什么,各自占用多少字节。 String类能被继承吗,为什么。 String,Stringbuffer,StringBuilder的区别。
kafka 0.11x 启动30秒后自动停止,报【另一个程序正在使用此文件,进程无法访问】
环境:kafka_2.11-1.1.0,win7_64,java8 现象: 启动30秒后自动停止,报【另一个程序正在使用此文件,进程无法访问】 [2018-06-06 14:32:46,784] INFO [Log partition=myTopic-0, dir=D:\kafka_2.
Flink-Table-SQL系列之source
source作为Table&SQL API的数据源,同时也是程序的入口。当前Flink的Table&SQL API整体而言支持三种source:Table source、DataSet以及DataStream,它们都通过特定的API注册到Table环境对象。
RocketMQ大数据畅想
刚刚过去的双十一,阿里自主研发的消息中间件RocketMQ,充分展现了它的低延迟特性,大部分消息请求落在2ms内,慢请求也都落在20ms内,这无疑给追求快速响应的在线交易系统(OLTP)带去了福音。 也是在今年11月份,RocketMQ进入Apache孵化。这款最初设计来为淘宝交易系统异步解耦、削峰填谷的消息中间件,开始走出国门,为世界上的用户提供服务。自然地,RocketMQ将来不仅仅只服务于
免费试用