kaf
个人专栏

最新文章

Spring Webflux监控客户端连接断开的方法

Spring webflux的FluxSink有两个方法:onCancel和onDispose。当客户端的连接断开,这两个方法会被调用。示例代码:@RestControllerpublic class Controller { @GetMapping("/") public Flux<String> test() { return Flux.create(this::proc

Kafka集群搭建

Kafka介绍 Kafka是一种高吞吐量的分布式发布订阅消息系统,有如下特性: 通过O(1)的磁盘数据结构提供消息的持久化,这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能。 高吞吐量:即使是非常普通的硬件kafka也可以支持每秒数十万的消息。 支持通过kafka服务器和消费机集群来分区消息。 支持Hadoop并行数据加载。 Kafka的目的是提供一个

Spring Boot集成kafka

Spring Boot对kafka提供了自动配置(auto configuration)。使用用Spring Boot只需要做很少的配置即可集成对kafka的访问。pom配置1、继承spring-boot-starter-parent<parent>   <groupId>org.springframework.boot&l