1. 程式人生 > >spring 整合 kafka

spring 整合 kafka

使用spring-integration-kafka傳送訊息

Outbound Channel Adapter用來發送訊息到Kafka。 訊息從Spring Integration Channel中讀取。 你可以在Spring application context指定這個channel。
一旦配置好這個Channel,就可以利用這個Channel往Kafka發訊息。 明顯地,Spring Integration特定的訊息傳送給這個Adaptor,然後傳送前在內部被轉為Kafka訊息。當前的版本要求你必須指定訊息key和topic作為頭部資料 (header),訊息作為有載荷(payload)。
例如

123456
final MessageChannel channel = ctx.getBean("inputToKafka", MessageChannel.class);channel.send(        MessageBuilder.withPayload(payload) //設定有效載荷                .setHeader("messageKey", "key") //指定key                .setHeader("topic", "test").build()); /指定topic/

實際程式碼如下:

12345678910111213141516171819202122232425262728
import java.util.Random;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.integration.support.MessageBuilder;import org.springframework.messaging.MessageChannel;public class Producer {	private static final String CONFIG = "/context.xml";	private
static Random rand = new Random(); public static void main(String[] args) { final ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext(CONFIG, Producer.class); ctx.start(); final MessageChannel channel = ctx.getBean("inputToKafka", MessageChannel.class); for (int i = 0; i < 100; i++) { channel.send(MessageBuilder.withPayload("Message-" + rand.nextInt()).setHeader("messageKey", String.valueOf(i)).setHeader("topic", "test").build()); } try { Thread.sleep(100000); } catch (InterruptedException e) { e.printStackTrace(); } ctx.close(); }}

Spring 配置檔案:

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"       
            
           

相關推薦

Spring整合Kafka中的事務

       原文連結:https://docs.spring.io/spring-kafka/reference/htmlsingle/#transactions 事務Transactions  &nb

SPRING 整合 KAFKA 傳送訊息

準備工作 1.安裝kafka+zookeeper環境  2.利用命令建立好topic,建立一個topic my-topic 整合步驟 1.配置生產者 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns=

spring 整合 kafka

使用spring-integration-kafka傳送訊息 Outbound Channel Adapter用來發送訊息到Kafka。 訊息從Spring Integration Channel中讀取。 你可以在Spring application context

Spring整合Kafkaspring-kafka

配置檔案的方式實現spring整和kafka:    此文主要講述的內容:     1,連線kafka伺服器的配置    2,kafka-customer:消費者配置    3,kafka-provider:提供者配置    4,KfkaUtils:根據topic傳送訊息 

spring整合kafka例項

1.依賴jar <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="

Spring 整合Kafka(完整版)

前面的文章我們已經完成了Kafka基於Zookeeper的叢集的搭建了。Kafka叢集搭建請點我。記過幾天的研究已經實現Spring的集成了。本文重點 jar包準備 整合是基於spring-i

spring 整合kafka監聽消費

前言 最近專案裡有個需求,要消費kafka裡的資料。之前也手動寫過程式碼去消費kafka資料。但是轉念一想。既然spring提供了消費kafka的方法。就沒必要再去重複造輪子。於是嘗試使用spring的API。 專案技術背景,使用springMVC,XML配置和註解相互使用。kafka的配置都是使用XML方式

Java架構-spring+springmvc+kafka分散式訊息中介軟體整合方案

Honghu的訊息服務平臺已經拋棄了之前的ActiveMQ,改用高吞吐量比較大的Kafka分散式訊息中介軟體方案: kafka訊息平臺使用spring+kafka的整合方案,詳情如下: 使用最高版本2.1.0.RELEASE整合jar包:spring-integration

Spring cloud 整合kafka

  Kafka配置 一.安裝 wget http://mirror.bit.edu.cn/apache/kafka/2.1.0/kafka_2.11-2.1.0.tgz  獲取當前版本 tar  -xzvf  解壓 二.配置 listeners=P

KafkaSpring整合實踐

目錄 安裝Zookeeper 安裝Kafka 建立一個Spring專案 使用Producer API傳送訊息到Kafka 使用Kafka High Level API接收訊息 使用spring-integration-kafka傳送訊息 使用spring

spring boot整合kafka

1.pom.xml <dependency> <groupId> org.apache.kafka</groupId> <artifactId> kafka_2.10</artifactId&

spring-boot 整合kafka單節點訊息傳送與接收

springboot還處於學習階段,又同時在學習kafka,兩者結合,繼續學習。 1、官網下載kafka 2、解壓 3、對於單節點來說,按照官網上操作即可實現訊息的傳送和接收。 但是對於客戶端,是通過 @KafkaListener 註解監聽生產者傳送的訊

Spring Cloud Bus整合Kafka

Kafka是由LinkedIn開發並開源的分散式訊息系統,因其分散式及高吞吐率而被廣泛使用,現已與Cloudera Hadoop,Apache Storm,Apache Spark整合,具備許多優秀的效能:高吞吐、分散式、跨平臺、實時性以及伸縮性,本文我們就來看

Spring Cloud 整合 kafka

kafka的安裝部署請參考:kafka安裝部署1、在pom.xml裡面新增kafka的maven依賴<dependency> <groupId>org.springframew

使用spring整合kafka收發訊息

1. 引入maven依賴 <dependency> <groupId>org.springframework.integration</groupId> <artifactId>spring-integration-kaf

Spring註解方式整合Kafkaspring-kafka的使用)

import java.util.HashMap; import java.util.Map; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.common

SpringKafka整合實戰

首先下載解壓zookeeper,選擇合適的映象站點以加快下載速度。我們可以將zookeeper加到系統服務中, 增加一個/etc/init.d/zookeeper檔案。 cd /opt wget http://apache.fayea.com/apache-mirror/zookeeper/zookeep

Spring Boot教程十二:整合Kafka

Kafka是最初由Linkedin公司開發,是一個分散式、支援分割槽的(partition)、多副本的(replica),基於zookeeper協調的分散式訊息系統,它的最大的特性就是可以實時的處理大量

SpringKafka 整合

– Start Spring 提供了介面來整合 Kafka。請參考《》瞭解更多詳情。 – 更多參見: – 聲 明:轉載請註明出處 – Last Updated on 2018-06-14 – Written by ShangBo on 2018

Spring Boot整合kafka筆記

kafka官網 http://kafka.apache.org/quickstartspring-kafka當前穩定版本是1.2.0..RELEASE  http://docs.spring.io/spring-kafka/docs/1.2.0.RELEASE/reference/html/_introduc