springboot 통합 kafka 메시지 Exception thrown when sending a message with key=andpayload='1'to topic test
886 단어 kafka
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
오류 배열:
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 로그 수준에서 하트비트 로그를 인쇄합니다.
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Spring Cloud를 사용한 기능적 Kafka - 1부지금까지 찾을 수 없었던 Spring Cloud Kafka의 작업 데모를 만들기 위해 이 기사를 정리했습니다. Confluent 스키마 레지스트리 7.1.0 이 기사는 먼저 Spring Cloud Stream을 사용...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.