spring cloud stream kafka實(shí)例

maven

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Camden.SR6</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-stream-binder-kafka</artifactId>
    </dependency>

生產(chǎn)者配置

server:
  port: 8081
spring:
  application:
    name: output-demo
  cloud:
     instance-count: 1
     instance-index: 0
     stream:
        kafka:
          binder:
            brokers: localhost:9092
            zk-nodes: localhost:2182
            auto-add-partitions: true
            auto-create-topics: true
            min-partition-count: 1
        bindings:
          output:
            destination: event-demo
            content-type: text/plain
            producer:
              partitionCount: 1


  • java代碼
@EnableBinding(Source.class)
public class SendService {

    @Autowired
    private Source source;

    public void sendMessage(String msg) {
        try {
            source.output().send(MessageBuilder.withPayload(msg).build());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

@RestController
public class ProducerController {
    
    @Autowired
    private SendService service;
    
    @RequestMapping(value = "/send/{msg}", method = RequestMethod.GET)
    public void send(@PathVariable("msg") String msg){
        service.sendMessage(msg);
    }
    
}

消費(fèi)者

spring:
  application:
    name: input-demo
  cloud:
     instance-count: 1
     instance-index: 0
     stream:
        kafka:
          binder:
            brokers: localhost:9092
            zk-nodes: localhost:2182
            auto-add-partitions: true
            auto-create-topics: true
            min-partition-count: 1
        bindings:
          input:
            destination: event-demo
            group: s1
            consumer:
              autoCommitOffset: false
              concurrency: 1
              partitioned: false
  • java代碼
@EnableBinding(Sink.class)
public class MsgSink {

    @StreamListener(Sink.INPUT)
    public void process(Message<?> message) {
        System.out.println(message.getPayload());
        Acknowledgment acknowledgment = message.getHeaders().get(KafkaHeaders.ACKNOWLEDGMENT, Acknowledgment.class);
        if (acknowledgment != null) {
            System.out.println("Acknowledgment provided");
            acknowledgment.acknowledge();
        }
    }
}

運(yùn)行

先運(yùn)行生產(chǎn)者,再運(yùn)行消費(fèi)者

curl -i localhost:8081/send/hello1

doc

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市杯聚,隨后出現(xiàn)的幾起案子拔恰,更是在濱河造成了極大的恐慌诲锹,老刑警劉巖驳规,帶你破解...
    沈念sama閱讀 211,561評(píng)論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件斥赋,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡氛琢,警方通過查閱死者的電腦和手機(jī)喊递,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,218評(píng)論 3 385
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來阳似,“玉大人骚勘,你說我怎么就攤上這事。” “怎么了俏讹?”我有些...
    開封第一講書人閱讀 157,162評(píng)論 0 348
  • 文/不壞的土叔 我叫張陵当宴,是天一觀的道長(zhǎng)。 經(jīng)常有香客問我泽疆,道長(zhǎng)即供,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 56,470評(píng)論 1 283
  • 正文 為了忘掉前任于微,我火速辦了婚禮逗嫡,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘株依。我一直安慰自己驱证,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 65,550評(píng)論 6 385
  • 文/花漫 我一把揭開白布恋腕。 她就那樣靜靜地躺著抹锄,像睡著了一般。 火紅的嫁衣襯著肌膚如雪荠藤。 梳的紋絲不亂的頭發(fā)上伙单,一...
    開封第一講書人閱讀 49,806評(píng)論 1 290
  • 那天,我揣著相機(jī)與錄音哈肖,去河邊找鬼吻育。 笑死,一個(gè)胖子當(dāng)著我的面吹牛淤井,可吹牛的內(nèi)容都是我干的布疼。 我是一名探鬼主播,決...
    沈念sama閱讀 38,951評(píng)論 3 407
  • 文/蒼蘭香墨 我猛地睜開眼币狠,長(zhǎng)吁一口氣:“原來是場(chǎng)噩夢(mèng)啊……” “哼游两!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起漩绵,我...
    開封第一講書人閱讀 37,712評(píng)論 0 266
  • 序言:老撾萬榮一對(duì)情侶失蹤贱案,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后止吐,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體宝踪,經(jīng)...
    沈念sama閱讀 44,166評(píng)論 1 303
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 36,510評(píng)論 2 327
  • 正文 我和宋清朗相戀三年祟印,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了肴沫。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片粟害。...
    茶點(diǎn)故事閱讀 38,643評(píng)論 1 340
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡蕴忆,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出悲幅,到底是詐尸還是另有隱情套鹅,我是刑警寧澤站蝠,帶...
    沈念sama閱讀 34,306評(píng)論 4 330
  • 正文 年R本政府宣布,位于F島的核電站卓鹿,受9級(jí)特大地震影響菱魔,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜吟孙,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 39,930評(píng)論 3 313
  • 文/蒙蒙 一澜倦、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧杰妓,春花似錦藻治、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,745評(píng)論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至倍宾,卻和暖如春雏节,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背高职。 一陣腳步聲響...
    開封第一講書人閱讀 31,983評(píng)論 1 266
  • 我被黑心中介騙來泰國(guó)打工钩乍, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人怔锌。 一個(gè)月前我還...
    沈念sama閱讀 46,351評(píng)論 2 360
  • 正文 我出身青樓件蚕,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國(guó)和親产禾。 傳聞我的和親對(duì)象是個(gè)殘疾皇子排作,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 43,509評(píng)論 2 348

推薦閱讀更多精彩內(nèi)容

  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn)亚情,斷路器妄痪,智...
    卡卡羅2017閱讀 134,633評(píng)論 18 139
  • ** 今天看了一下kafka官網(wǎng),嘗試著在自己電腦上安裝和配置楞件,然后學(xué)一下官方document衫生。** Introd...
    RainChang閱讀 4,993評(píng)論 1 30
  • 發(fā)行說明 - Kafka - 版本1.0.0 以下是Kafka 1.0.0發(fā)行版中解決的JIRA問題的摘要。有關(guān)該...
    全能程序猿閱讀 2,854評(píng)論 2 7
  • 很久以前就注意到,在線教育領(lǐng)域里,被誤解最多的一個(gè)詞就是課程了. 在大部分行業(yè)從業(yè)者口里, 課程就意味著一系列的教...
    Zhoumo01閱讀 1,585評(píng)論 0 1
  • 一個(gè)項(xiàng)目不使用開源技術(shù)框架幾乎不可能土浸,或多或少要用到一些開源技術(shù)框架罪针。在引入新的開源框架之前需要進(jìn)行選型,進(jìn)行充分...
    小猴蕩秋千閱讀 1,918評(píng)論 0 4