消息中间件

首页 标签 消息中间件
# 消息中间件 #
关注
28268内容
Windows环境下Flink消费Kafka实现热词统计
前言碎语 昨天博主写了《windows环境下flink入门demo实例》实现了官方提供的最简单的单词计数功能,今天升级下,将数据源从socket流换成生产级的消息队列kafka来完成一样的单词计数功能。
拼多多&快手研发面经
版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/a724888/article/details/82702450 拼多多&快手研发面经 本文首发于微信公众号:程序员江湖 快手:Java研发工程师 面试共有三轮 技术面试两轮,一面40分钟,二面1个小时。
kafka SSL证书生成及配置
apache kafka可以使用SSL加密连接,还可以限制客户端访问, 给客户端发行证书,只允许持有证书的客户端访问。 下面使用jdk的keytool工具来生成证书,配置kafka。
protobuf (序列化协议)
出品方为google,详见ibm技术文档: http://www.ibm.com/developerworks/cn/linux/l-cn-gpb/ 1.简介 Protocol Buffers 是一种轻便高效的结构化数据存储格式,可以用于结构化数据串行化,或者说序列化。它很适合做数据存储或 RPC 数据交换格式。可用于通讯协议、数据存储等领域的语言无关、平台无关、可扩展的序列化结构
Flink Broadcast State实用指南
从1.5.0开始,Flink提供了一种新的State类型,称为Broadcast State。在这篇文章中,我们将解释什么是Broadcast State,并展示如何将其应用于评估事件流上的动态模式的应用的示例。
免费试用