国产 无码 综合区,色欲AV无码国产永久播放,无码天堂亚洲国产AV,国产日韩欧美女同一区二区

記一次 springboot集成kafka-本地連接服務器的kafka,連接不上的問題

這篇具有很好參考價值的文章主要介紹了記一次 springboot集成kafka-本地連接服務器的kafka,連接不上的問題。希望對大家有所幫助。如果存在錯誤或未考慮完全的地方,請大家不吝賜教,您也可以點擊"舉報違法"按鈕提交疑問。

yml中配置了bootstrap-servers: 服務器地址:9092,但是連接時卻報了
Connection to node -1 (localhost/127.0.0.1:9092) could not be established.

17:23:08.731 [kafka-admin-client-thread | adminclient-1] WARN  o.a.k.c.NetworkClient - [processDisconnection,782] - [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
17:23:11.738 [kafka-admin-client-thread | adminclient-1] WARN  o.a.k.c.NetworkClient - [processDisconnection,782] - [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
17:23:14.889 [kafka-admin-client-thread | adminclient-1] WARN  o.a.k.c.NetworkClient - [processDisconnection,782] - [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
17:23:18.115 [kafka-admin-client-thread | adminclient-1] WARN  o.a.k.c.NetworkClient - [processDisconnection,782] - [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
17:23:21.010 [kafka-admin-client-thread | adminclient-1] WARN  o.a.k.c.NetworkClient - [processDisconnection,782] - [AdminClient clientId=adminclient-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
17:23:21.355 [kafka-admin-client-thread | adminclient-1] INFO  o.a.k.c.a.i.AdminMetadataManager - [updateFailed,235] - [AdminClient clientId=adminclient-1] Metadata update failed
org.apache.kafka.common.errors.TimeoutException: Call(callName=fetchMetadata, deadlineMs=1687685001348, tries=1, nextAllowedTryMs=1687685001449) timed out at 1687685001349 after 1 attempt(s)
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: fetchMetadata
17:23:21.369 [restartedMain] ERROR o.s.k.c.KafkaAdmin - [error,149] - Could not configure topics
org.springframework.kafka.KafkaException: Timed out waiting to get existing topics; nested exception is java.util.concurrent.TimeoutException

chat給我的回復如下,通過一些列檢查我確定了在服務器上,kafka沒有問題
kafka無法連接,kafka,spring boot,docker
最后還是從一篇博客中的第一句話得到了答案,博客鏈接放在最下方
kafka無法連接,kafka,spring boot,docker
我是docker安裝的kafka,因此修改配置文件的步驟如下:

docker exec -it ${CONTAINER ID} /bin/bash
vi /opt/kafka/config/server.properties

advertised.listeners=PLAINTEXT://112.126.74.249:9092

kafka無法連接,kafka,spring boot,docker

鏈接: https://www.cnblogs.com/shenyixin/p/17445164.html文章來源地址http://www.zghlxwxcb.cn/news/detail-796404.html

到了這里,關(guān)于記一次 springboot集成kafka-本地連接服務器的kafka,連接不上的問題的文章就介紹完了。如果您還想了解更多內(nèi)容,請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!

本文來自互聯(lián)網(wǎng)用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權(quán),不承擔相關(guān)法律責任。如若轉(zhuǎn)載,請注明出處: 如若內(nèi)容造成侵權(quán)/違法違規(guī)/事實不符,請點擊違法舉報進行投訴反饋,一經(jīng)查實,立即刪除!

領(lǐng)支付寶紅包贊助服務器費用

相關(guān)文章

  • 記一次線上kafka造成的事故

    背景:所有的原始數(shù)據(jù)均存儲在mysql,mysql會通過binlog將數(shù)據(jù)同步至kafka消息隊列,但是有人將mysql中的數(shù)據(jù)進行刪除(大概有2、3年的數(shù)據(jù)),被刪除的數(shù)據(jù)也通過binlog被同步至消息隊列里導致大量消息積壓,且該消息隊列只有3個分區(qū),最多3個線程消費,消費方即使過濾也遠

    2024年02月13日
    瀏覽(19)
  • 【kafka】記一次kafka基于linux的原生命令的使用

    【kafka】記一次kafka基于linux的原生命令的使用

    環(huán)境是linux,4臺機器,版本3.6,kafka安裝在node 1 2 3 上,zookeeper安裝在node2 3 4上。 安裝好kafka,進入bin目錄,可以看到有很多sh文件,是我們執(zhí)行命令的基礎。 啟動kafka,下面的命令的后面帶的配置文件的相對路徑 遇到不熟悉的sh文件,直接輸入名字并回車,就會提示你可用的

    2024年02月05日
    瀏覽(26)
  • 記一次Flink通過Kafka寫入MySQL的過程

    記一次Flink通過Kafka寫入MySQL的過程

    一、前言 總體思路:source --transform --sink ,即從source獲取相應的數(shù)據(jù)來源,然后進行數(shù)據(jù)轉(zhuǎn)換,將數(shù)據(jù)從比較亂的格式,轉(zhuǎn)換成我們需要的格式,轉(zhuǎn)換處理后,然后進行sink功能,也就是將數(shù)據(jù)寫入的相應的數(shù)據(jù)庫DB中或者寫入Hive的HDFS文件存儲。 思路: pom部分放到最后面。 二

    2024年01月24日
    瀏覽(27)
  • 記一次線上kafka重復消費的問題解決及思考

    線上ELK日志發(fā)現(xiàn)kafka消費者消費到重復消息 由于生產(chǎn)方本身就發(fā)送了重復的消息,導致消費到重復消息 消費方采用的是循環(huán)poll的模式,具體是在多線程分租戶去批量處理的消息

    2024年02月10日
    瀏覽(19)
  • 記一次Kafka 故障Too many open files問題

    記一次Kafka 故障Too many open files問題

    查看日志發(fā)現(xiàn),有kafka日志報錯提示: 查看limit.conf文件,發(fā)現(xiàn)文件打開數(shù)設置的值也沒問題,嘗試增大值后,但就是提示Too many open files,報錯就是文件打開數(shù)過多。 經(jīng)不懈的百度百度,發(fā)現(xiàn)如下圖兩條關(guān)鍵信息; systemd 服務 模塊 最大打開文件數(shù)默認為1024,查看其他沒改動

    2024年02月13日
    瀏覽(22)
  • 記一次MOXA串口服務器使用

    記一次MOXA串口服務器使用

    AIS船臺——天線——AIS基站——網(wǎng)線——交換機——服務器 AIS船臺——天線——AIS基站——串口線——串口服務器——網(wǎng)線——交換機——服務器 串口線分為RS-485、RS-422、RS-232,此處以RS-232為例 串口線:一端為RS232連接頭,用于連接串口服務器 一端為裸露的電線纖芯頭,用

    2024年02月03日
    瀏覽(29)
  • 記一次heapdump泄漏獲取服務器權(quán)限

    一、漏洞原因 掃描目錄發(fā)現(xiàn)某個spring框架存在大量泄露信息的路徑,訪問ip/heapdump可直接下載內(nèi)存文件; 通過分析heapdump獲取redis數(shù)據(jù)庫權(quán)限 利用定時任務,進行反彈shell獲取服務器權(quán)限 二、漏洞利用 1、通過目錄掃描發(fā)現(xiàn)heapdump文件

    2024年02月02日
    瀏覽(24)
  • 記一次springboot項目漏洞挖掘

    前段時間的比賽將該cms作為了題目考察,這個cms的洞也被大佬們吃的差不多了,自己也就借此機會來淺淺測試下這個cms殘余漏洞,并記錄下這一整個流程,謹以此記給小白師傅們分享下思路,有錯誤的地方還望大佬們請以指正。 參考官方文檔,給出了很詳細的安裝說明,如安

    2024年02月03日
    瀏覽(18)
  • 記一次jedis連接池頑固問題排查與修改

    記一次jedis連接池頑固問題排查與修改

    這輩子不想再看到jedisBrokenPipe!! ? 測試環(huán)境運行16天后報錯信息: 05:42:32.629 [http-nio-8093-exec-2] ERROR o.a.c.c.C.[.[.[.[dispatcherServlet] - [log,175] - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is redis.clients.jedis.exceptions.JedisCon

    2023年04月21日
    瀏覽(42)
  • 記一次服務器Cuda驅(qū)動崩潰修復過程

    今天實驗室?guī)熜衷诜掌鬟\行深度學習訓練時候得到報錯CUDA initialization: Unexpected error from cudaGetDeviceCount()疑似Cuda與NVIDIA顯卡驅(qū)動溝通中出現(xiàn)了問題,使用 nvidia-smi 指令時提示 Failed to initialize NVML: Driver/library version mismatch ,經(jīng)過溝通了解到,重啟與重新配置Cuda環(huán)境均未能解決

    2024年02月08日
    瀏覽(29)

覺得文章有用就打賞一下文章作者

支付寶掃一掃打賞

博客贊助

微信掃一掃打賞

請作者喝杯咖啡吧~博客贊助

支付寶掃一掃領(lǐng)取紅包,優(yōu)惠每天領(lǐng)

二維碼1

領(lǐng)取紅包

二維碼2

領(lǐng)紅包