alpakka-kafka(7)-kafka应用案例，消费模式
producer从四面八方同时、集中将消息写入kafka。库存管理平台在kafka消费端不间断监控kafka里新的未 ...
原文：alpakka-kafka(1)-producer
alpakka项目是一个基于akka streams流处理编程工具的scala java开源项目，通过提供connector连接各种数据源并在akka streams里进行数据处理。alpakka kafka就是alpakka项目里的kafka connector。对于我们来说：可以用alpakka kafka来对接kafka，使用kafka提供的功能。或者从另外一个角度讲：alpakka ka ...
2021-02-20 09:08 0 283 推荐指数：
相关推荐
alpakka-kafka(8)-kafka数据消费模式实现
上篇介绍了kafka at-least-once消费模式。kafka消费模式以commit-offset的时间节点代表不同的消费模式，分别是：at-least-once, at-most-once, exactly-once。上篇介绍的at-least-once消费模式是通过kafka ...
alpakka-kafka(6)-kafka应用案例，用户接口
了解了kafka原理之后，对kafka的的应用场景有了一些想法。在下面的一系列讨论中把最近一个项目中关于kafka的应用介绍一下。 先介绍一下使用kafka的起因：任何进销存系统，销售开单部分都应该算是主体部分了。简单的说，这是一个包括销售数据录入、库存数扣减两个动作的过程。销售项目 ...
alpakka-kafka(5)-kafka集群配置与分布式应用部署
在进入具体的kafka应用设计之前我们先把kafka集群环境配置介绍一下。多节点kafka-cluster的安装、配置非常简单，所以应该不用太多篇幅就可以完成一个完整可用的kafka-cluster环境了： 1、安装Kafka之前需要安装zookeeper。无论zookeeper或者kafka ...
kafka producer源码
producer接口： View Code producer接口由两个实现类KafkaProducer、MockProducer KafkaProducer类： View Code MockProducer类 ...
Kafka Producer接口
参考， https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example http://kafka.apache.org/08/configuration.html , 0.8版本，关于producer ...
关于Kafka幂等producer的讨论
众所周知，Kafka 0.11.0.0版本正式支持精确一次处理语义(exactly once semantics，下称EOS)。Kafka的EOS主要体现在3个方面： 幂等producer：保证发送单个分区的消息只会发送一次，不会出现重复消息 事务(transaction)：保证 ...
详解Kafka Producer
上一篇文章我们主要介绍了什么是 Kafka，Kafka 的基本概念是什么，Kafka 单机和集群版的搭建，以及对基本的配置文件进行了大致的介绍，还对 Kafka 的几个主要角色进行了描述，我们知道，不管是把 Kafka 用作消息队列、消息总线还是数据存储平台来使用，最终是绕不过消息这个词的，这也 ...