日日操夜夜添-日日操影院-日日草夜夜操-日日干干-精品一区二区三区波多野结衣-精品一区二区三区高清免费不卡

公告:魔扣目錄網(wǎng)為廣大站長提供免費收錄網(wǎng)站服務(wù),提交前請做好本站友鏈:【 網(wǎng)站目錄:http://www.ylptlb.cn 】, 免友鏈快審服務(wù)(50元/站),

點擊這里在線咨詢客服
新站提交
  • 網(wǎng)站:51998
  • 待審:31
  • 小程序:12
  • 文章:1030137
  • 會員:747

本文介紹了如何使用Quarkus在Kafka中設(shè)置同一主題中的多個消費者的處理方法,對大家解決問題具有一定的參考價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)吧!

問題描述

我正在使用Quarkus框架構(gòu)建一個Kafka消費者,它將讀取帶有3個分區(qū)的主題。下面的代碼片段正在工作,但根據(jù)日志,我只是啟動了具有3個分區(qū)的1個使用者。我現(xiàn)在的問題是,一旦我運行我的應(yīng)用程序,我如何才能產(chǎn)生3個消費者。

@Incoming("topic-1")
public CompletionStage<Void> onMessage(KafkaRecord<String, String> message) throws IOException {

    LOG.info("Kafka order message with value = {} arrived from topic {} ", message.getPayload(),
            message.getTopic());

    //JsonObject event = new JsonObject(message.getPayload());

    try {
        if (true) {
            LOG.info("Kafka message: " + message);
        }
    } catch (Exception e) {
        e.printStackTrace();
    }

    return message.ack();
}

請參閱示例日志:

信息[org.apa.kaf.cli.con.int.Consumer協(xié)調(diào)器](vert.x-kafka-Consumer-線程-0)[消費者客戶端ID=測試消費者,組ID=kafka-檢測-消費者]已完成第64代的組的分配:{testconsumer-bf6d314c-44e1-47b1-9439-fe4058951841=Assignment(partitions=[test_part-0,TEST_PART-1,TEST_PART-2])}

推薦答案

如果您在Containers平臺(Docker、K8s…)上運行應(yīng)用程序然后,您可以橫向擴展您的服務(wù);否則,請使用不同的端口再次運行您的應(yīng)用程序。

Kafka客戶端啟動時會被分配到某個分區(qū),因此同一個客戶端不能從多個Theme-Partition消費。

這篇關(guān)于如何使用Quarkus在Kafka中設(shè)置同一主題中的多個消費者的文章就介紹到這了,希望我們推薦的答案對大家有所幫助,

分享到:
標簽:Kafka Quarkus 主題 多個 如何使用 消費者 設(shè)置
用戶無頭像

網(wǎng)友整理

注冊時間:

網(wǎng)站:5 個   小程序:0 個  文章:12 篇

  • 51998

    網(wǎng)站

  • 12

    小程序

  • 1030137

    文章

  • 747

    會員

趕快注冊賬號,推廣您的網(wǎng)站吧!
最新入駐小程序

數(shù)獨大挑戰(zhàn)2018-06-03

數(shù)獨一種數(shù)學(xué)游戲,玩家需要根據(jù)9

答題星2018-06-03

您可以通過答題星輕松地創(chuàng)建試卷

全階人生考試2018-06-03

各種考試題,題庫,初中,高中,大學(xué)四六

運動步數(shù)有氧達人2018-06-03

記錄運動步數(shù),積累氧氣值。還可偷

每日養(yǎng)生app2018-06-03

每日養(yǎng)生,天天健康

體育訓(xùn)練成績評定2018-06-03

通用課目體育訓(xùn)練成績評定