alpakka项目是一个基于akka-streams流处理编程工具的scala/java开源项目，通过提供connector连接各种数据源并在akka-streams里进行数据处理。alpakka-kafka就是alpakka项目里的kafka-connector。对于我们来说：可以用 ...

上篇描述的kafka案例是个库存管理平台。是一个公共服务平台，为其它软件模块或第三方软件提供库存状态管理服务。当然，平台管理的目标必须是共享的，即库存是作为公共资源开放的。这个库存管理平台是一个Kafka消费端独立运行的软件。kafka的生产方即平台的服务对象通过kafka生产端 ...

了解了kafka原理之后，对kafka的的应用场景有了一些想法。在下面的一系列讨论中把最近一个项目中关于kafka的应用介绍一下。 先介绍一下使用kafka的起因：任何进销存系统，销售开单部分都应该算是主体部分了。简单的说，这是一个包括销售数据录入、库存数扣减两个动作的过程。销售项目 ...

　　一、kafka简介 　　kafka是基于发布/订阅模式的一个分布式消息队列系统，用java语言研发，是ASF旗下的一个开源项目；类似的消息队列服务还有rabbitmq、activemq、zeromq；kafka最主要的优势具备分布式功能，并且结合zookeeper可以实现动态扩容；kafka ...

上篇介绍了kafka at-least-once消费模式。kafka消费模式以commit-offset的时间节点代表不同的消费模式，分别是：at-least-once, at-most-once, exactly-once。上篇介绍的at-least-once消费模式是通过kafka ...

Docker+K8S 集群环境搭建及分布式应用部署 https://blog.csdn.net/ysk_xh_521/article/details/81668631 https://blog.csdn.net/zhenliang8/article/details/78611004 ...

作者 | fanux.中弈 来源 | 阿里巴巴云原生公众号 什么是集群镜像 ​ 顾名思义，和操作系统 .iso 镜像或 Docker 镜像类似，集群镜像是用一定的技术手段把整个集群的所有文件以一定格式打成的一个资源包。 ​ 对比单机和集群会发现一些的有趣现象： ​ 单机有计算 ...

环境说明 kafka自0.9之后增加了connector的特性。本文主要是搭建一个分布式的kafka connector和broker。 本文用了三台机器进行部署，使用centos 6.6。 hostname ip role ...