springboot 통합 kafka 메시지 Exception thrown when sending a message with key=andpayload='1'to topic test

886 단어 kafka
로컬 환경springboot 통합 kafka 메시지 오류 발생 Exception thrown when sending a message with key='andpayload='1'to topic test
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for test-0 due to 30049 ms has passed since batch creation plus linger time
오류 배열:
  • 서버 방화벽이 닫혔습니다. 로컬 텔넷 연결 9092 포트는 문제없습니다
  • kafka 프로필listeners=PLAINTEXT:/{내망 ip}:9092
  • 프로젝트 로그 레벨을 DEBUG로 조정하여 시작 과정을 잘못 보고했습니다
  • Connection with /{ ip} disconnected
    java.net.ConnectException: Connection timed out: no further information 
    Initiating connection to node 0 at { ip}:9092.

    이로써 알 수 있듯이 오류 원인은 로컬에서 서버 네트워크 IP에 접근할 수 없기 때문입니다
    해결 방법:
    kafka 프로필 서버를 수정합니다.properties
    listeners=PLAINTEXT:/{네트워킹 IP}:9092
    advertised.listeners=PLAINTEXT:/{외부 네트워크 IP}:9092
    로컬 프로젝트를 다시 시작하여 메시지를 성공적으로 보내고 DEBUG 로그 수준에서 하트비트 로그를 인쇄합니다.

    좋은 웹페이지 즐겨찾기