Spring 的 Kafka 抽象 Spring Kafka

Spring 的 Kafka 抽象 Spring Kafka

Apache-2.0
Java 查看源码»
跨平台
Pivotal
2018-07-06
局长

Spring for Apache Kafka (spring-kafka) 项目将 Spring 核心概念应用于基于 Kafka 的消息传递解决方案的开发。它提供了一个“模板”作为发送消息的高级抽象。它还通过 @KafkaListener 注解和“侦听器容器(listener container)”为消息驱动的 POJO 提供支持。

这些库促进了依赖注入和声明的使用。在所有这些用例中,你将看到 Spring Framework 中的 JMS 支持和 Spring AMQP 中的 RabbitMQ 支持的相似之处。

功能特性

  • KafkaTemplate

  • KafkaMessageListenerContainer

  • @KafkaListener

  • KafkaTransactionManager

  • 带嵌入式 kafka 服务器的 spring-kafka-test jar 包

的码云指数为
超过 的项目
加载中

评论(0)

暂无评论

Spring Kafka 2.2.2 发布

Spring Kafka 2.2.2 已发布,变更记录: 84eec92 InvocationResult: Fix checking for null

2018/11/30 10:52

Spring Kafka 2.2.1 发布

Spring Kafka 2.2.1 发布。 b69a453 (master) Upgrade dependencies & fix lambdas for method ref 4390405 Add appendix for 2.1.x kafka-clients jar 6c79d95 GH-878: Polishing - Fix ne...

2018/11/28 09:17

Spring Kafka 2.1.10 和 2.2.0.M3 发布

Spring Kafka 2.1.10 和 2.2.0.M3 发布了。更新内容如下 Spring Kafka 2.1.10 d8b4ba1 Upgrade SF to 5.0.9 950a999 GH-800: Fix Zombie Fencing db84b14 Doc: Partition Assignment Spring ...

2018/09/11 16:19

Spring Kafka 2.1.9 发布,Spring 的 Kafka 抽象

Spring Kafka 2.1.9 已发布,更新内容如下: GH-777: Reset running on stop() GH-782: Fix GenericMessageListener Javadocs GH-780: Fix typo GH-780: More 2.0.0 Doc Polishing GH-780: ...

2018/08/27 16:37

Spring Kafka 2.2.0.M2 发布,Spring 的 Kafka 抽象

Spring Kafka 2.2.0.M2 已发布,更新内容如下: Polish KafkaTemplate.executeInTransaction() GH-777: Reset running on stop() GH-782: Fix GenericMessageListener Javadocs Upgrade SF t...

2018/08/21 10:20

Spring Kafka 1.3.6 和 2.1.8 发布,Spring 的 Kafka 抽象

Spring Kafka 1.3.6 和 2.1.8 已发布,更新内容如下: 2.1.8 更新日志: Upgrade to Spring Data Kay SR9 Upgrade Spring Framework, Data, Clients versions GH-753: Close transactional ...

2018/07/29 14:08

Spring Kafka 2.2.0.M1 发布,Spring 的 Kafka 抽象

Spring Kafka 2.2.0.M1 已发布,更新内容如下: Upgrade Clients to 1.1.1 Upgrade Spring Framework, Data to RC1 GH-753: Close transactional producer on error GH-732: Refactor KafkaE...

2018/07/27 09:09

Spring Kafka 2.1.7 发布,Spring 的 Kafka 抽象

Spring Kafka 2.1.7 发布了,更新内容如下: b80fbd4 Fix varargs warn for CompositeProducerListener 4fe846d GH-686: Handle tombstones in Json Ser/Deser 62e9325 GH-690: Propagate A...

2018/06/15 11:09

Spring Kafka 2.1.6 和 2.0.5 发布,常规更新版本

Spring Kafka 2.1.6 和 2.0.5 已发布,Spring Kafka 是 Spring 官方提供的一个 Spring 集成框架的扩展,用来为使用 Spring 框架的应用程序提供 Kafka 框架的集成。 2.1.6 更新日志 9ddfd52 ...

2018/05/09 08:00

Spring Kafka 2.1.5 和 2.0.4 发布,包含大量更新

Spring Kafka 2.0.4 与 2.1.5 发布,包含大量更新。 更新详情 d408c27 GH-637: Fix spurious nonresponsive consumer events 3706405 GH-634: 1.1.0 Client compatibility e77e1ef GH-621: ...

2018/04/08 14:34

没有更多内容

加载失败,请刷新页面

1
回答
同一个工程消费多个kafka集群的多个topic

同一个工程消费多个kafka集群的多个topic 手动根据配置实例KafkaListenerContainerFactory 然后一个kafka集群用 一...

2018/08/14 20:19

没有更多内容

加载失败,请刷新页面

没有更多内容

Kafka 入门和 Spring Boot 集成

# Kafka 入门和 Spring Boot 集成 # 概述 kafka 是一个高性能的消息队列,也是一个分布式流处理平台(这里的流指的是数据流)。由java 和 Scala 语言编写,最早由 LinkedIn 开发,并 2011年开...

2018/06/05 22:33
1K
3
【SpringBoot整合】1.整合kafka

简介 kafka简介。 再次之前,先安装kafka服务。 参考文档: spring for kafka文档 spring boot for kafka文档 1、依赖包 <!-- kafka --> <dependency> <groupId>org.springframework.kafka</...

03/14 09:34
29
0
使用Spring Request-Reply实现基于Kafka的同步请求响应

大家提到Kafka时第一印象就是它是一个快速的异步消息处理系统,不同于通常tomcat之类应用服务器和前端之间的请求/响应方式请求,客户端发出一个请求,必然会等到一个响应,这种方式对Kafka来...

2018/10/11 16:50
13
0
Kafka集成Spring-AcknowledgeMessageListener接口实现

前言 因工作需要,需在系统利用Kafka监听接口,实现消息队列中,对消息的消费,首选Kafka,因为看中其超高的吞吐量。 基本概念 1 Producer: 特指消息的生产者 2 Consumer :特指消息的消费者 ...

2018/05/10 17:26
336
0
eureka + kafka +zookeeper

eureka 配置中心,注册中心环境搭建 1. eureka-server 1.1 pom.xml <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi=&quo......

2018/06/08 08:41
51
0
使用Spring Request-Reply实现基于Kafka的同步请求响应

大家提到Kafka时第一印象就是它是一个快速的异步消息处理系统,不同于通常tomcat之类应用服务器和前端之间的请求/响应方式请求,客户端发出一个请求,必然会等到一个响应,这种方式对Kafka来...

2018/10/11 16:45
6
0

没有更多内容

加载失败,请刷新页面

返回顶部
顶部