我很高興宣布 spring-kafka (Spring for Apache Kafka) 的第一個里程碑版本現在可用 (1.0.0.M1)。

現有的 spring-integration-kafka 擴充專案 - 目前版本為 1.3.0.RELEASE，支援 Kafka 0.8.x.x，並用於 Spring XD (Kafka MessageBus) 和 Spring Cloud Stream (Kafka Binder)。

這個新的專案 (spring-kafka) 將核心元件拆分為一個獨立的專案。 它基於新的 0.9.0.x 純 Java Kafka 客戶端。

spring-kafka 將熟悉的 Spring 程式設計模型帶給 Apache Kafka，適用於任何 Spring 使用者，而不僅僅是使用 Spring Integration 的使用者。 即將發布的 spring-integration-kafka 版本將完全重寫，並在內部使用 spring-kafka 專案。

與 Spring 系列中的其他訊息傳遞專案非常相似，spring-kafka 提供：

• 訊息監聽器容器。
• 適用於 POJO 訊息監聽器的註解 (@KafkaListener - 類似於 @JmsListener 和 @RabbitListener)。
• 用於同步和非同步傳送到 Kafka 主題的 KafkaTemplate

@Configuration
@EnableKafka
public class KafkaConfig {
     // Infrastructure @Beans omitted. 
     // See Reference Manual and tests for comprehensive sample

     @Bean
     public Listener listener() {
        return new Listener();
     }

}

public class Listener {

     @KafkaListener(topics = "myTopic")
     public void handleFromKakfa(String payload) {
       ...
    }

}

使用 Maven 或 Gradle

<dependencies>
    <dependency>
        <groupId>org.springframework.kafka</groupId>
        <artifactId>spring-kafka</artifactId>
        <version>1.0.0.M1</version>
    </dependency>
</dependencies>

dependencies {
    compile 'org.springframework.kafka:spring-kafka:1.0.0.M1'
}

此外，spring-kafka-test artifact 可用，其中包含對測試的支援，包括嵌入式 Kafka broker、hamcrest Matcher 等。

這兩個 artifact 都在 repo.spring.io/milestone 儲存庫中可用。

請參閱 里程碑 1 參考手冊 以獲取更多資訊。

非常感謝 Soby Chacko（啟動最初的 Spring Integration Kafka 擴充功能）、Marius Bogoevici 和 Artem Bilan 對這個重要專案的幫助。

#後續步驟

• 基於 spring-kafka 的 spring-integration-kafka (2.0) 的第一個里程碑版本
• Spring Boot starter，具有自動設定支援等。
• spring-cloud-stream 的新 Binder 實作
• 充實文件、建立專案頁面等。

同時，您可以在 github repo 中追蹤進度、報告問題等。