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

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();	}}

<?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整合Kafka之spring-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 

  
 

    

    
    
Kafka和Spring整合實踐
     
 
							
							
							目錄




安裝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註解方式整合Kafka（spring-kafka的使用）
     
 
                

import java.util.HashMap;
import java.util.Map;

import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common 

  
 

    

    
    
Spring 與 Kafka整合實戰
     
 
首先下載解壓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協調的分散式訊息系統，它的最大的特性就是可以實時的處理大量 

  
 

    

    
    
Spring 與 Kafka 整合
     
 
							
							
							– 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