乙個服務配置多個kafka

2022-10-05 15:54:14 字數 1161 閱讀 8280

//今天在用kafka接收資料的時候遇到乙個問題,後註冊的配置位址資訊會把前乙個配置位址覆蓋,多方驗證後發現是註冊bean的時候出問題了。

//因為不在乙個類中,但是配置檔案共用的乙個,所以寫了多個獲取配置的方法,監聽功能再去監聽資訊的時候獲取到的配置檔案是預設的,預設的資訊就是最後注入的那個位址bootstrap.server

//注意工廠2沒有指定工廠資訊,需要指定的話配置如下**

//containe***ctory ="需要指定的工廠"

//配置消費者工廠1

public consume***ctoryconsumer1factory()

//獲取配置檔案1

public mapconsumerconfig1()

//配置消費者工廠2

public consume***ctoryconsume***ctory()

//獲取配置檔案2

public mapconsumerconfigs()

//通過不同的配置工廠生成例項bean

//topic消費1

@bean("kafkalistenercontainernwfactory")

public kafkalistenercontaine***ctory>

kafkalistenercontainernwfactory()

//topic消費1

@bean

public kafkalistenercontaine***ctory> kafkalistenercontaine***ctory()

//配置監聽訊息

//topic1

@kafkalistener(topics = "#'.split(',')}",containe***ctory ="kafkalistenercontainernwfactory")

public void listen(list> records,acknowledgment ack) throws ioexception {}

//topic2

@kafkalistener(topics = "#'.split(',')}")

public void listen(list> records,acknowledgment ack) throws ioexception {}

乙個伺服器上配置多個tomcat

電腦上裝了兩個tomcat,乙個6乙個7.當第乙個tomcat啟動後,後面tomcat的server.xml中的埠不管怎麼改,仍然會報埠衝突。後來在dos下執行才發現所有的tomcat都會去找catalina home和catalina base這兩個環境變數,因此步驟如下 1.使用壓縮版的tomc...

乙個伺服器中配置多個tomcat

由於工作的原因,需要在乙個伺服器中配置多個tomcat。在網上找了許多的資料,發現在自己的機子上用不了。當第乙個tomcat啟動後,後面tomcat的server.xml中的埠不管怎麼改,仍然會報埠衝突。後來在dos下執行才發現所有的tomcat都會去找catalina home和catalina ...

乙個Tomcat配置多個埠

二 tomcat 8.0 配置多個埠,其實也就是給tomcat增加幾個server,並設定對應目錄。下面以增加兩個埠號為例 第一步 修改server.xml tomcat 8.0 conf 1 tomcat提供的如下 unpackwars true autodeploy true 當然了,埠號別忘了...