第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

Spring Cloud 流/Kafka 異常

Spring Cloud 流/Kafka 異常

慕尼黑8549860 2021-09-12 20:21:07
我對使用 spring 云流和 kafka 的服務(wù)有問題。該服務(wù)一直工作正常,但昨天開始報告啟動時出現(xiàn)一系列異常:一段時間后,我們會看到這樣的異常:Caused by: org.springframework.messaging.core.DestinationResolutionException: failed to look up MessageChannel with name '946859a6-bc27-466d-91ba-3da93af50ac9:1' in the BeanFactory.; nested exception is org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named '946859a6-bc27-466d-91ba-3da93af50ac9:1' available與 kafka 的連接配置了一個屬性: spring.kafka.bootstrap-server = kafka.kafka:9092并且主題配置了 Spring Cloud 流屬性: spring.cloud.stream.bindings.[topic-name].destination = blah與 kafka 的交互通過 spring 與如下代碼集成進行:@MessagingGatewaypublic interface StreamGateway {     @Gateway(requestChannel = KafkaConfig.ENRICH_PAYMENT, replyChannel = ChannelNames.PAYMENT_REPLY, replyTimeout = 10000)     String processPayment(String payload);}//不同的類:private final StreamGateway gateway;...gateway.processPayment(message)這是在 azure kubernetes 部署上運行,而 kafka 與 spring boot 服務(wù)位于一個單獨的 pod 中。提前致謝。更新: 問題再次發(fā)生,一些進一步的調(diào)查強調(diào)了一些事情因為我們使用 spring 集成@MessagingGateway并@Gateway創(chuàng)建與 Kafka 的同步交互,所以沒有正常的主題StreamListener或訂閱者當主題存在滯后時會出現(xiàn)問題,即主題中存在超出主題偏移量的消息。缺少正常StreamListener意味著無法處理滯后消息。只有當 MessageGateway 建立連接時,才有可能從主題中讀取消息。解決問題的一種方法是讀取所有“滯后”消息,使滯后為 0。然后服務(wù)將正常啟動,但是如果我手動將消息發(fā)布到主題(與 MessageGateway 交互),則錯誤再次發(fā)生。第二個部分解決方案(我還沒有完全理解)是向@DependsOnMessageGateway添加一個注釋,表明它需要一個使用@InputSubscribableChannel 對象單獨創(chuàng)建的 bean 。這意味著 SubscribableChannel 必須在 MessageGateway 之前創(chuàng)建,因此創(chuàng)建了一個訂閱者,但是仍然沒有 StreamListener,因此當從主題中拉出滯后消息時仍然會拋出異常,無處可去 ??
查看完整描述

2 回答

?
拉風(fēng)的咖菲貓

TA貢獻1995條經(jīng)驗 獲得超2個贊

在查看調(diào)試日志時,我注意到該服務(wù)正確連接到其他主題,但付款回復(fù)主題存在問題。我嘗試刪除此主題并重新啟動服務(wù)。這解決了問題。


查看完整回答
反對 回復(fù) 2021-09-12
  • 2 回答
  • 0 關(guān)注
  • 257 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動學(xué)習(xí)伙伴

公眾號

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號